public class PartitionRpo extends Object
Constructor and Description |
---|
PartitionRpo(TopicIdPartition topicIdPartition) |
PartitionRpo(TopicIdPartition topicIdPartition,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
mayAddSegmentAndCreateTime(long baseOffset,
long timestamp) |
protected void |
mayLoadPartitionRpo(kafka.log.MergedLog log)
Load initial SegmentAncCreateTime list for the PartitionRpo if it is not loaded before.
|
void |
removeSegmentByFirstUntieredOffset(long firstUntieredOffset)
Clean segments from the RPO tracking if their endOffset are less than firstUntieredOffset.
|
long |
rpo()
The segment list are appended based on its createTime, so the head of the list is the
oldest segment that hasn't been protected.
|
String |
toString() |
public PartitionRpo(TopicIdPartition topicIdPartition)
public PartitionRpo(TopicIdPartition topicIdPartition, org.apache.kafka.common.utils.Time time)
public long rpo()
public void mayAddSegmentAndCreateTime(long baseOffset, long timestamp)
public void removeSegmentByFirstUntieredOffset(long firstUntieredOffset)
protected void mayLoadPartitionRpo(kafka.log.MergedLog log)