public class RpoMetricsManager extends Object implements TierReplicaManager.ChangeListener
Constructor and Description |
---|
RpoMetricsManager(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
addNewSegment(TopicIdPartition topicIdPartition,
long baseOffset) |
protected static long |
getValue(RpoValue[] values,
double quantile)
Returns the value at the given quantile from the input values array.
|
void |
onBecomeFollower(TopicIdPartition topicIdPartition)
Fired when this topic partition becomes follower.
|
void |
onBecomeLeader(TopicIdPartition topicIdPartition,
int leaderEpoch)
Implement methods for TierReplicaManager.ChangeListener
|
void |
onDelete(TopicIdPartition topicIdPartition)
Fired when this topic partition is deleted.
|
PartitionRpo |
partitionRpo(TopicIdPartition topicIdPartition) |
void |
registerTopicIdPartition(TopicIdPartition topicIdPartition)
Hook methods, which will be called in corresponding segment lifecycle.
|
void |
unregisterTopicIdPartition(TopicIdPartition topicIdPartition) |
void |
updateRpoValues(kafka.log.LogManager logManager) |
public RpoMetricsManager(org.apache.kafka.common.utils.Time time)
public void updateRpoValues(kafka.log.LogManager logManager)
public void registerTopicIdPartition(TopicIdPartition topicIdPartition)
public void unregisterTopicIdPartition(TopicIdPartition topicIdPartition)
public void addNewSegment(TopicIdPartition topicIdPartition, long baseOffset)
public PartitionRpo partitionRpo(TopicIdPartition topicIdPartition)
protected static long getValue(RpoValue[] values, double quantile)
quantile
- a given quantile, in [0, 1]public void onBecomeLeader(TopicIdPartition topicIdPartition, int leaderEpoch)
onBecomeLeader
in interface TierReplicaManager.ChangeListener
public void onBecomeFollower(TopicIdPartition topicIdPartition)
TierReplicaManager.ChangeListener
onBecomeFollower
in interface TierReplicaManager.ChangeListener
public void onDelete(TopicIdPartition topicIdPartition)
TierReplicaManager.ChangeListener
onDelete
in interface TierReplicaManager.ChangeListener