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) |
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) |
Modifier and Type | Method and Description |
---|---|
CompactStats |
accumulatedCompactStats() |
long |
compactDirtyStartOffset() |
long |
endOffset() |
boolean |
equals(Object o) |
OffsetAndEpoch |
errorOffsetAndEpoch() |
OffsetAndEpoch |
globalMaterializedOffsetAndEpoch() |
int |
hashCode() |
CompactStats |
lastCompactStats() |
OffsetAndEpoch |
localMaterializedOffsetAndEpoch() |
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)
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)
public int tierEpoch()
public UUID topicId()
public TierPartitionStatus status()
public 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()