public class TierMetadataSnapshotUploadComplete extends AbstractTierMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
CURRENT_VERSION |
static byte |
VERSION_V1 |
static byte |
VERSION_V2 |
static byte |
VERSION_V3 |
Constructor and Description |
---|
TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate,
FileTierPartitionStateSnapshotObject snapshotObject) |
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
OffsetAndEpoch stateOffset,
OffsetAndEpoch snapshotOffset,
long snapshotTimestampMs,
byte checksumAlgorithm) |
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
MetadataSnapshotUploadComplete metadata) |
Modifier and Type | Method and Description |
---|---|
Algorithm |
checksumAlgorithm() |
static int |
initialBufferSize()
The initial buffer size to use when constructing the FlatBuffer message.
|
UUID |
messageId()
Get a unique id for this message.
|
ByteBuffer |
payloadBuffer() |
OffsetAndEpoch |
snapshotOffsetAndEpoch() |
long |
snapshotTimestampMs() |
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() |
byte |
version() |
deserialize, deserialize, deserializeKey, deserializeKey, equals, getTypeId, hashCode, messageIdAsBase64, serializeKey, serializeValue, timestamp
public static final byte VERSION_V1
public static final byte VERSION_V2
public static final byte VERSION_V3
public static final byte CURRENT_VERSION
public TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, OffsetAndEpoch stateOffset, OffsetAndEpoch snapshotOffset, long snapshotTimestampMs, byte checksumAlgorithm)
public TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, MetadataSnapshotUploadComplete metadata)
public TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate, FileTierPartitionStateSnapshotObject snapshotObject)
public static int initialBufferSize()
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 OffsetAndEpoch snapshotOffsetAndEpoch()
public ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public long snapshotTimestampMs()
public Algorithm checksumAlgorithm()
public byte version()