public class Header extends Object
Modifier and Type | Field and Description |
---|---|
static UUID |
SNAPSHOT_ID_EMPTY |
Constructor and Description |
---|
Header(TierPartitionStateHeader header) |
Header(UUID topicId,
byte version,
int tierEpoch,
TierPartitionStatus status,
long startOffset,
long endOffset,
OffsetAndEpoch globalMaterializedOffsetAndEpoch,
OffsetAndEpoch localMaterializedOffsetAndEpoch,
OffsetAndEpoch errorOffsetAndEpoch,
OffsetAndEpoch lastRestoredOffsetAndEpoch,
boolean hasStateChangeTimestamp,
boolean tierPartitionStateSnapshotFeatureFlag,
long lastSnapshotTimestampMs,
UUID lastSnapshotId) |
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,
boolean tierPartitionStateSnapshotFeatureFlag,
long lastSnapshotTimestampMs,
UUID lastSnapshotId) |
Modifier and Type | Method and Description |
---|---|
CompactStats |
accumulatedCompactStats() |
long |
compactDirtyStartOffset() |
boolean |
compactFeatureFlag() |
long |
endOffset() |
boolean |
equals(Object o) |
OffsetAndEpoch |
errorOffsetAndEpoch() |
OffsetAndEpoch |
globalMaterializedOffsetAndEpoch() |
boolean |
hasCompactDirtyStartOffset() |
int |
hashCode() |
boolean |
hasSnapshotInfo() |
boolean |
hasStateChangeTimestamp() |
CompactStats |
lastCompactStats() |
UUID |
lastSnapshotId() |
long |
lastSnapshotTimestampMs() |
OffsetAndEpoch |
localMaterializedOffsetAndEpoch() |
void |
mutateStartOffset(long startOffset) |
ByteBuffer |
payloadBuffer() |
OffsetAndEpoch |
restoreOffsetAndEpoch() |
long |
size() |
long |
startOffset() |
TierPartitionStatus |
status() |
int |
tierEpoch() |
boolean |
tierPartitionStateSnapshotFeatureFlag() |
String |
toJson() |
UUID |
topicId() |
String |
toString() |
short |
version() |
byte |
versionInByte() |
public static final UUID SNAPSHOT_ID_EMPTY
public Header(TierPartitionStateHeader header)
public Header(UUID topicId, byte version, int tierEpoch, TierPartitionStatus status, long startOffset, long endOffset, OffsetAndEpoch globalMaterializedOffsetAndEpoch, OffsetAndEpoch localMaterializedOffsetAndEpoch, OffsetAndEpoch errorOffsetAndEpoch, OffsetAndEpoch lastRestoredOffsetAndEpoch, boolean hasStateChangeTimestamp, boolean tierPartitionStateSnapshotFeatureFlag, long lastSnapshotTimestampMs, UUID lastSnapshotId)
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, boolean tierPartitionStateSnapshotFeatureFlag, long lastSnapshotTimestampMs, UUID lastSnapshotId)
public ByteBuffer payloadBuffer()
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 boolean hasCompactDirtyStartOffset()
public CompactStats lastCompactStats()
public CompactStats accumulatedCompactStats()
public boolean hasStateChangeTimestamp()
public long lastSnapshotTimestampMs()
public UUID lastSnapshotId()
public boolean hasSnapshotInfo()
public boolean compactFeatureFlag()
public boolean tierPartitionStateSnapshotFeatureFlag()
public String toJson()