public class TierSegmentUploadInitiate extends AbstractTierSegmentMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
CURRENT_VERSION |
static byte |
VERSION_V1 |
static byte |
VERSION_V2 |
Constructor and Description |
---|
TierSegmentUploadInitiate(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
long baseOffset,
long endOffset,
long maxTimestamp,
long firstBatchTimestamp,
int size,
boolean hasEpochState,
boolean hasAbortedTxns,
boolean hasProducerState,
TierUploadType uploadType,
OffsetAndEpoch stateOffset,
TierObjectStore.OpaqueData opaqueData) |
TierSegmentUploadInitiate(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
Optional<UUID> previousObjectId,
long baseOffset,
long endOffset,
long maxTimestamp,
long firstBatchTimestamp,
int size,
boolean hasEpochState,
boolean hasAbortedTxns,
boolean hasProducerState,
TierUploadType uploadType,
OffsetAndEpoch stateOffset,
TierObjectStore.OpaqueData opaqueData) |
TierSegmentUploadInitiate(TopicIdPartition topicIdPartition,
SegmentUploadInitiate metadata) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
long |
endOffset() |
boolean |
equals(Object o) |
long |
firstBatchTimestamp() |
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
static int |
initialBufferSize()
The initial buffer size to use when constructing the FlatBuffer message.
|
long |
maxTimestamp() |
UUID |
messageId()
Get a unique id for this message.
|
TierObjectStore.OpaqueData |
opaqueData() |
ByteBuffer |
payloadBuffer() |
Optional<UUID> |
previousObjectId() |
int |
size() |
TierObjectMetadata.State |
state()
The current state of the segment.
|
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() |
TierUploadType |
uploadType() |
objectId, objectIdAsBase64
deserialize, deserialize, deserializeKey, deserializeKey, getTypeId, messageIdAsBase64, serializeKey, serializeValue, timestamp
public static final byte VERSION_V1
public static final byte VERSION_V2
public static final byte CURRENT_VERSION
public TierSegmentUploadInitiate(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, long baseOffset, long endOffset, long maxTimestamp, long firstBatchTimestamp, int size, boolean hasEpochState, boolean hasAbortedTxns, boolean hasProducerState, TierUploadType uploadType, OffsetAndEpoch stateOffset, TierObjectStore.OpaqueData opaqueData)
public TierSegmentUploadInitiate(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, Optional<UUID> previousObjectId, long baseOffset, long endOffset, long maxTimestamp, long firstBatchTimestamp, int size, boolean hasEpochState, boolean hasAbortedTxns, boolean hasProducerState, TierUploadType uploadType, OffsetAndEpoch stateOffset, TierObjectStore.OpaqueData opaqueData)
public TierSegmentUploadInitiate(TopicIdPartition topicIdPartition, SegmentUploadInitiate metadata)
public static int initialBufferSize()
public TierObjectMetadata.State state()
AbstractTierSegmentMetadata
state
in class AbstractTierSegmentMetadata
public long baseOffset()
public long endOffset()
public long maxTimestamp()
public int size()
public boolean hasEpochState()
public boolean hasAbortedTxns()
public boolean hasProducerState()
public TierUploadType uploadType()
public long firstBatchTimestamp()
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 TierObjectStore.OpaqueData opaqueData()
public ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public boolean equals(Object o)
equals
in class AbstractTierMetadata
public int hashCode()
hashCode
in class AbstractTierMetadata