public class SegmentState extends Object
Constructor and Description |
---|
SegmentState(int tierEpoch,
UUID objectId,
long baseOffset,
long keyBaseOffset,
long endOffset,
long maxTimestamp,
long firstBatchTimestamp,
int size,
TierObjectMetadata.State state,
boolean hasEpochState,
boolean hasAbortedTxns,
boolean hasProducerState,
TierUploadType uploadType,
TierObjectStore.OpaqueData opaqueData,
long filePosition) |
SegmentState(TierObjectMetadata metadata,
long virtualBaseOffset,
long filePosition) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
SegmentState |
boundBaseOffset(long updatedBaseOffset)
Return a new SegmentState with a bounded base offset
|
long |
endOffset() |
boolean |
equals(Object o) |
int |
filePosition() |
long |
firstBatchTimestamp() |
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
long |
keyBaseOffset() |
long |
maxTimestamp() |
UUID |
objectId() |
TierObjectStore.OpaqueData |
opaqueData() |
int |
size() |
TierObjectMetadata.State |
state() |
int |
tierEpoch() |
String |
toString() |
SegmentState |
updateState(TierObjectMetadata.State updatedState)
Return a new SegmentState with the updated state
|
TierUploadType |
uploadType() |
public SegmentState(TierObjectMetadata metadata, long virtualBaseOffset, long filePosition)
public SegmentState(int tierEpoch, UUID objectId, long baseOffset, long keyBaseOffset, long endOffset, long maxTimestamp, long firstBatchTimestamp, int size, TierObjectMetadata.State state, boolean hasEpochState, boolean hasAbortedTxns, boolean hasProducerState, TierUploadType uploadType, TierObjectStore.OpaqueData opaqueData, long filePosition)
public long endOffset()
public long baseOffset()
public long keyBaseOffset()
public TierObjectStore.OpaqueData opaqueData()
public SegmentState updateState(TierObjectMetadata.State updatedState)
updatedState
- updated state of the segmentpublic SegmentState boundBaseOffset(long updatedBaseOffset)
updatedBaseOffset
- updated base offset for the segmentpublic TierObjectMetadata.State state()
public UUID objectId()
public long maxTimestamp()
public long firstBatchTimestamp()
public int size()
public int tierEpoch()
public boolean hasAbortedTxns()
public boolean hasEpochState()
public boolean hasProducerState()
public TierUploadType uploadType()
public int filePosition()