public class TierObjectMetadata extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TierObjectMetadata.State |
Constructor and Description |
---|
TierObjectMetadata(TierSegmentUploadInitiate uploadInitiate) |
TierObjectMetadata(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
long baseOffset,
long endOffset,
long maxTimestamp,
int size,
TierObjectMetadata.State state,
boolean hasEpochState,
boolean hasAbortedTxns,
boolean hasProducerState,
TierObjectStore.OpaqueData opaqueData) |
TierObjectMetadata(TopicIdPartition topicIdPartition,
TierPartitionStateEntry metadata) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
long |
endOffset() |
boolean |
equals(Object o) |
void |
forceMutateState(TierObjectMetadata.State newState)
To mutate state without canTransitionTo rules checking.
|
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
long |
maxTimestamp() |
void |
mutateState(TierObjectMetadata.State newState) |
UUID |
objectId()
Random ID associated with each TierObjectMetadata entry.
|
String |
objectIdAsBase64() |
TierObjectStore.OpaqueData |
opaqueData() |
ByteBuffer |
payloadBuffer()
Returns the internal Flatbuffers representation backing this TierObjectMetadata.
|
int |
payloadSize() |
int |
size() |
TierObjectMetadata.State |
state() |
int |
tierEpoch() |
TopicIdPartition |
topicIdPartition() |
String |
toString() |
short |
version() |
public TierObjectMetadata(TopicIdPartition topicIdPartition, TierPartitionStateEntry metadata)
public TierObjectMetadata(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, long baseOffset, long endOffset, long maxTimestamp, int size, TierObjectMetadata.State state, boolean hasEpochState, boolean hasAbortedTxns, boolean hasProducerState, TierObjectStore.OpaqueData opaqueData)
public TierObjectMetadata(TierSegmentUploadInitiate uploadInitiate)
public TopicIdPartition topicIdPartition()
public ByteBuffer payloadBuffer()
public int payloadSize()
public int tierEpoch()
public long baseOffset()
public UUID objectId()
public String objectIdAsBase64()
public long endOffset()
public long maxTimestamp()
public int size()
public boolean hasEpochState()
public boolean hasAbortedTxns()
public TierObjectMetadata.State state()
public void mutateState(TierObjectMetadata.State newState)
public void forceMutateState(TierObjectMetadata.State newState)
newState
- the target state to transit topublic boolean hasProducerState()
public TierObjectStore.OpaqueData opaqueData()
public short version()