public class TierMetadataSnapshotUploadComplete extends AbstractTierMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
CURRENT_VERSION |
protected MetadataSnapshotUploadComplete |
metadata |
static byte |
VERSION_V1 |
timestamp
Constructor and Description |
---|
TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate,
long snapshotTimestampMs) |
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
OffsetAndEpoch stateOffset,
long snapshotTimestampMs) |
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
MetadataSnapshotUploadComplete metadata) |
Modifier and Type | Method and Description |
---|---|
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() |
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() |
deserialize, deserialize, deserializeKey, deserializeKey, equals, getTypeId, hashCode, messageIdAsBase64, serializeKey, serializeValue, timestamp
public static final byte VERSION_V1
public static final byte CURRENT_VERSION
protected final MetadataSnapshotUploadComplete metadata
public TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, OffsetAndEpoch stateOffset, long snapshotTimestampMs)
public TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate, long snapshotTimestampMs)
public TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, MetadataSnapshotUploadComplete metadata)
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 ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public long snapshotTimestampMs()