public class FtpsSegmentView extends Object
Constructor and Description |
---|
FtpsSegmentView(org.apache.kafka.common.TopicPartition topicPartition,
File stateFile,
long fromTimestamp) |
FtpsSegmentView(org.apache.kafka.common.TopicPartition topicPartition,
File stateFile,
long fromTimestamp,
boolean bOffsetConsecutive) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Header |
header() |
int |
indexOf(UUID segmentObjectId)
Find the index of the given segment in segmentStateList
|
int |
segmentCountWithState(TierObjectMetadata.State state) |
List<SegmentState> |
segmentStateList() |
Map<UUID,SegmentState> |
segmentStateMap() |
CheckedFileIO |
stateFileChannel() |
TopicIdPartition |
topicIdPartition() |
void |
updateFtpsHeader(Header newHeader) |
void |
updateFtpsHeaderLogStartOffset(Long newLogStartOffset)
In-place update FTPS header with new log start offset
|
public FtpsSegmentView(org.apache.kafka.common.TopicPartition topicPartition, File stateFile, long fromTimestamp) throws IOException
IOException
public FtpsSegmentView(org.apache.kafka.common.TopicPartition topicPartition, File stateFile, long fromTimestamp, boolean bOffsetConsecutive) throws IOException
IOException
public int indexOf(UUID segmentObjectId)
public void updateFtpsHeaderLogStartOffset(Long newLogStartOffset) throws IOException
newLogStartOffset
- IOException
public void updateFtpsHeader(Header newHeader) throws IOException
IOException
public TopicIdPartition topicIdPartition()
public List<SegmentState> segmentStateList()
public Map<UUID,SegmentState> segmentStateMap()
public CheckedFileIO stateFileChannel()
public void close() throws IOException
IOException
public Header header()
public int segmentCountWithState(TierObjectMetadata.State state)