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,
TierObjectMetadata.State stateBeforeDeletion,
long filePosition) |
SegmentState(TierObjectMetadata metadata,
long filePosition) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
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() |
TierObjectMetadata.State |
stateBeforeDeletion() |
int |
tierEpoch() |
String |
toString() |
SegmentState |
updateState(TierObjectMetadata.State updatedState)
Return a new SegmentState with the updated state
|
TierUploadType |
uploadType() |
public SegmentState(TierObjectMetadata metadata, 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, TierObjectMetadata.State stateBeforeDeletion, 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 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 TierObjectMetadata.State stateBeforeDeletion()
public int filePosition()