public class TierObjectMetadata
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TierObjectMetadata.State |
Constructor and Description |
---|
TierObjectMetadata(TierSegmentUploadInitiate uploadInitiate) |
TierObjectMetadata(TopicIdPartition topicIdPartition,
int tierEpoch,
java.util.UUID objectId,
long baseOffset,
long endOffset,
long maxTimestamp,
int size,
TierObjectMetadata.State state,
boolean hasEpochState,
boolean hasAbortedTxns,
boolean hasProducerState) |
TierObjectMetadata(TopicIdPartition topicIdPartition,
TierPartitionStateEntry metadata) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
TierObjectMetadata |
duplicate() |
long |
endOffset() |
boolean |
equals(java.lang.Object o) |
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
long |
maxTimestamp() |
void |
mutateState(TierObjectMetadata.State newState) |
java.util.UUID |
objectId()
Random ID associated with each TierObjectMetadata entry.
|
java.lang.String |
objectIdAsBase64() |
java.nio.ByteBuffer |
payloadBuffer() |
int |
payloadSize() |
int |
size() |
TierObjectMetadata.State |
state() |
int |
tierEpoch() |
TopicIdPartition |
topicIdPartition() |
java.lang.String |
toString() |
short |
version() |
public TierObjectMetadata(TopicIdPartition topicIdPartition, TierPartitionStateEntry metadata)
public TierObjectMetadata(TopicIdPartition topicIdPartition, int tierEpoch, java.util.UUID objectId, long baseOffset, long endOffset, long maxTimestamp, int size, TierObjectMetadata.State state, boolean hasEpochState, boolean hasAbortedTxns, boolean hasProducerState)
public TierObjectMetadata(TierSegmentUploadInitiate uploadInitiate)
public TierObjectMetadata duplicate()
public TopicIdPartition topicIdPartition()
public java.nio.ByteBuffer payloadBuffer()
public int payloadSize()
public int tierEpoch()
public long baseOffset()
public java.util.UUID objectId()
public java.lang.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 boolean hasProducerState()
public short version()
public java.lang.String toString()
toString
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object