public class TierObjectMetadata extends AbstractTierMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
ID |
Constructor and Description |
---|
TierObjectMetadata(org.apache.kafka.common.TopicPartition topicPartition,
int tierEpoch,
long startOffset,
int endOffsetDelta,
long lastStableOffset,
long maxTimestamp,
int size,
boolean epochState,
boolean aborts,
byte state) |
TierObjectMetadata(org.apache.kafka.common.TopicPartition topicPartition,
ObjectMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
long |
endOffset() |
int |
endOffsetDelta() |
boolean |
equals(java.lang.Object o) |
boolean |
hasAborts() |
boolean |
hasEpochState() |
int |
hashCode() |
long |
lastStableOffset() |
long |
maxTimestamp() |
java.util.UUID |
messageId()
Random ID associated with each TierObjectMetadata entry.
|
ObjectMetadata |
objectMetadata() |
java.nio.ByteBuffer |
payloadBuffer() |
int |
size() |
long |
startOffset() |
byte |
state() |
int |
tierEpoch()
tierEpoch for the tier metadata
|
org.apache.kafka.common.TopicPartition |
topicPartition()
Topic-partition corresponding to this tier metadata.
|
java.lang.String |
toString() |
byte |
type() |
short |
version() |
deserialize, serializeKey, serializeValue
public static final byte ID
public TierObjectMetadata(org.apache.kafka.common.TopicPartition topicPartition, ObjectMetadata metadata)
public TierObjectMetadata(org.apache.kafka.common.TopicPartition topicPartition, int tierEpoch, long startOffset, int endOffsetDelta, long lastStableOffset, long maxTimestamp, int size, boolean epochState, boolean aborts, byte state)
public ObjectMetadata objectMetadata()
public byte type()
type
in class AbstractTierMetadata
public java.nio.ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public int tierEpoch()
AbstractTierMetadata
tierEpoch
in class AbstractTierMetadata
public long startOffset()
public int endOffsetDelta()
public java.util.UUID messageId()
public long endOffset()
public long lastStableOffset()
public long maxTimestamp()
public int size()
public org.apache.kafka.common.TopicPartition topicPartition()
AbstractTierMetadata
topicPartition
in class AbstractTierMetadata
public boolean hasEpochState()
public boolean hasAborts()
public byte state()
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