public class TierUtils extends Object
Modifier and Type | Field and Description |
---|---|
static int |
ENTRY_LENGTH_SIZE |
Constructor and Description |
---|
TierUtils() |
Modifier and Type | Method and Description |
---|---|
static Optional<kafka.log.TierLogSegment> |
tierLogSegmentForOffset(TierPartitionState partitionState,
long offset) |
static TierObjectMetadata |
updateSegmentState(TopicIdPartition topicIdPartition,
SegmentState currentState,
TierObjectMetadata.State newState,
CheckedFileIO stateFileChannel)
In-place update segment's state
|
static TierObjectMetadata |
updateSegmentState(TopicIdPartition topicIdPartition,
SegmentState currentState,
TierObjectMetadata.State newState,
CheckedFileIO stateFileChannel,
boolean transitionCheck) |
public static final int ENTRY_LENGTH_SIZE
public static Optional<kafka.log.TierLogSegment> tierLogSegmentForOffset(TierPartitionState partitionState, long offset)
public static TierObjectMetadata updateSegmentState(TopicIdPartition topicIdPartition, SegmentState currentState, TierObjectMetadata.State newState, CheckedFileIO stateFileChannel) throws IOException
IOException
public static TierObjectMetadata updateSegmentState(TopicIdPartition topicIdPartition, SegmentState currentState, TierObjectMetadata.State newState, CheckedFileIO stateFileChannel, boolean transitionCheck) throws IOException
IOException