public class Header extends Object
Constructor and Description |
---|
Header(UUID topicId,
byte version,
int tierEpoch,
TierPartitionStatus status,
long startOffset,
long endOffset,
OffsetAndEpoch globalMaterializedOffsetAndEpoch,
OffsetAndEpoch localMaterializedOffsetAndEpoch,
OffsetAndEpoch errorOffsetAndEpoch,
OffsetAndEpoch lastRestoredOffsetAndEpoch,
boolean hasStateChangeTimestamp) |
Header(UUID topicId,
byte version,
int tierEpoch,
TierPartitionStatus status,
long startOffset,
long endOffset,
OffsetAndEpoch globalMaterializedOffsetAndEpoch,
OffsetAndEpoch localMaterializedOffsetAndEpoch,
OffsetAndEpoch errorOffsetAndEpoch,
OffsetAndEpoch lastRestoredOffsetAndEpoch,
boolean compactFeatureFlag,
long compactDirtyStartOffset,
CompactStats lastCompactStats,
CompactStats accumulatedCompactStats,
boolean hasStateChangeTimestamp) |
Modifier and Type | Method and Description |
---|---|
CompactStats |
accumulatedCompactStats() |
long |
compactDirtyStartOffset() |
long |
endOffset() |
boolean |
equals(Object o) |
OffsetAndEpoch |
errorOffsetAndEpoch() |
OffsetAndEpoch |
globalMaterializedOffsetAndEpoch() |
int |
hashCode() |
boolean |
hasStateChangeTimestamp() |
CompactStats |
lastCompactStats() |
OffsetAndEpoch |
localMaterializedOffsetAndEpoch() |
void |
mutateStartOffset(long startOffset) |
OffsetAndEpoch |
restoreOffsetAndEpoch() |
long |
size() |
long |
startOffset() |
TierPartitionStatus |
status() |
int |
tierEpoch() |
UUID |
topicId() |
String |
toString() |
short |
version() |
byte |
versionInByte() |
public Header(UUID topicId, byte version, int tierEpoch, TierPartitionStatus status, long startOffset, long endOffset, OffsetAndEpoch globalMaterializedOffsetAndEpoch, OffsetAndEpoch localMaterializedOffsetAndEpoch, OffsetAndEpoch errorOffsetAndEpoch, OffsetAndEpoch lastRestoredOffsetAndEpoch, boolean hasStateChangeTimestamp)
public Header(UUID topicId, byte version, int tierEpoch, TierPartitionStatus status, long startOffset, long endOffset, OffsetAndEpoch globalMaterializedOffsetAndEpoch, OffsetAndEpoch localMaterializedOffsetAndEpoch, OffsetAndEpoch errorOffsetAndEpoch, OffsetAndEpoch lastRestoredOffsetAndEpoch, boolean compactFeatureFlag, long compactDirtyStartOffset, CompactStats lastCompactStats, CompactStats accumulatedCompactStats, boolean hasStateChangeTimestamp)
public int tierEpoch()
public UUID topicId()
public TierPartitionStatus status()
public long startOffset()
public void mutateStartOffset(long startOffset)
public long endOffset()
public long size()
public short version()
public byte versionInByte()
public OffsetAndEpoch localMaterializedOffsetAndEpoch()
public OffsetAndEpoch globalMaterializedOffsetAndEpoch()
public OffsetAndEpoch restoreOffsetAndEpoch()
public OffsetAndEpoch errorOffsetAndEpoch()
public long compactDirtyStartOffset()
public CompactStats lastCompactStats()
public CompactStats accumulatedCompactStats()
public boolean hasStateChangeTimestamp()