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,
boolean transitionCheck,
long timestamp) |
static TierObjectMetadata |
updateSegmentState(TopicIdPartition topicIdPartition,
SegmentState currentState,
TierObjectMetadata.State newState,
CheckedFileIO stateFileChannel,
long timestamp)
In-place update segment's state
|
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, long timestamp) throws IOException
IOException
public static TierObjectMetadata updateSegmentState(TopicIdPartition topicIdPartition, SegmentState currentState, TierObjectMetadata.State newState, CheckedFileIO stateFileChannel, boolean transitionCheck, long timestamp) throws IOException
IOException