public class TierPartitionForceRestore extends AbstractTierMetadata
Constructor and Description |
---|
TierPartitionForceRestore(TopicIdPartition topicIdPartition,
PartitionForceRestore metadata) |
TierPartitionForceRestore(TopicIdPartition topicIdPartition,
java.util.UUID messageId,
long startOffset,
long endOffset,
OffsetAndEpoch stateOffsetAndEpoch,
java.lang.String contentHash) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
contentHash() |
long |
endOffset() |
int |
expectedSizeLatestVersion()
Test method for validating initial buffer size allocation
|
java.util.UUID |
messageId()
Get a unique id for this message.
|
java.nio.ByteBuffer |
payloadBuffer() |
long |
startOffset() |
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.
|
java.lang.String |
toString() |
TierRecordType |
type() |
byte |
version() |
deserialize, deserialize, deserializeKey, deserializeKey, equals, getTypeId, hashCode, messageIdAsBase64, serializeKey, serializeValue
public TierPartitionForceRestore(TopicIdPartition topicIdPartition, java.util.UUID messageId, long startOffset, long endOffset, OffsetAndEpoch stateOffsetAndEpoch, java.lang.String contentHash)
public TierPartitionForceRestore(TopicIdPartition topicIdPartition, PartitionForceRestore metadata)
public long startOffset()
public long endOffset()
public java.lang.String contentHash()
public byte version()
public TierRecordType type()
type
in class AbstractTierMetadata
public TopicIdPartition topicIdPartition()
AbstractTierMetadata
topicIdPartition
in class AbstractTierMetadata
public java.nio.ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public int tierEpoch()
AbstractTierMetadata
tierEpoch
in class AbstractTierMetadata
public OffsetAndEpoch stateOffsetAndEpoch()
AbstractTierMetadata
stateOffsetAndEpoch
in class AbstractTierMetadata
public java.util.UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public int expectedSizeLatestVersion()
AbstractTierMetadata
expectedSizeLatestVersion
in class AbstractTierMetadata
public java.lang.String toString()
toString
in class java.lang.Object