public class TierCompactionCommitAndSwap extends AbstractTierMetadata
Constructor and Description |
---|
TierCompactionCommitAndSwap(TierSegmentUploadInitiate uploadInitiate,
UUID messageId,
Set<UUID> sourceObjectIds,
long lastCleanOffset,
CompactStats compactStats) |
TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition,
CompactionCommitAndSwap metadata) |
TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition,
int tierEpoch,
OffsetAndEpoch stateOffset,
UUID messageId,
Set<UUID> sourceObjectIds,
Set<UUID> destinationObjectIds,
long lastCleanOffset,
CompactStats compactStats) |
TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID messageId,
UUID destinationObjectId,
OffsetAndEpoch stateOffset,
Set<UUID> sourceObjectIds,
long lastCleanOffset,
CompactStats stats) |
Modifier and Type | Method and Description |
---|---|
CompactStats |
compactStats() |
UUID |
destinationObjectIdsGet(int i) |
int |
destinationObjectIdsLength() |
long |
lastCleanOffset() |
UUID |
messageId()
Get a unique id for this message.
|
ByteBuffer |
payloadBuffer() |
UUID |
sourceObjectIdsGet(int i) |
int |
sourceObjectIdsLength() |
OffsetAndEpoch |
stateOffsetAndEpoch()
The lastMaterializedOffsetAndEpoch for the tier partition state at the time this metadata was generated.
|
int |
tierEpoch()
tierEpoch for the tier metadata
|
TopicIdPartition |
topicIdPartition()
Topic-partition corresponding to this tier metadata.
|
String |
toString() |
TierRecordType |
type() |
deserialize, deserialize, deserializeKey, deserializeKey, equals, getTypeId, hashCode, messageIdAsBase64, serializeKey, serializeValue
public TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition, int tierEpoch, OffsetAndEpoch stateOffset, UUID messageId, Set<UUID> sourceObjectIds, Set<UUID> destinationObjectIds, long lastCleanOffset, CompactStats compactStats)
public TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition, int tierEpoch, UUID messageId, UUID destinationObjectId, OffsetAndEpoch stateOffset, Set<UUID> sourceObjectIds, long lastCleanOffset, CompactStats stats)
public TierCompactionCommitAndSwap(TierSegmentUploadInitiate uploadInitiate, UUID messageId, Set<UUID> sourceObjectIds, long lastCleanOffset, CompactStats compactStats)
public TierCompactionCommitAndSwap(TopicIdPartition topicIdPartition, CompactionCommitAndSwap metadata)
public TierRecordType type()
type
in class AbstractTierMetadata
public TopicIdPartition topicIdPartition()
AbstractTierMetadata
topicIdPartition
in class AbstractTierMetadata
public int tierEpoch()
AbstractTierMetadata
tierEpoch
in class AbstractTierMetadata
public OffsetAndEpoch stateOffsetAndEpoch()
AbstractTierMetadata
stateOffsetAndEpoch
in class AbstractTierMetadata
public ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public int sourceObjectIdsLength()
public UUID sourceObjectIdsGet(int i)
public UUID destinationObjectIdsGet(int i)
public int destinationObjectIdsLength()
public long lastCleanOffset()
public CompactStats compactStats()