public class KafkaBrokerMetricSampleAggregator extends MetricSampleAggregator<BrokerEntity>
MetricSampleAggregator
Constructor and Description |
---|
KafkaBrokerMetricSampleAggregator(KafkaCruiseControlConfig config)
Construct the metric sample aggregator.
|
Modifier and Type | Method and Description |
---|---|
MetricSampleAggregationResult<BrokerEntity> |
aggregate(Set<BrokerEntity> brokerEntities)
Aggregate the metrics for the given brokers.
|
addSample, aggregate, aggregate, allWindows, availableWindows, clear, completeness, completeness, maybeInvalidateWindowsBeforeTime, numAvailableWindows, numAvailableWindows, numSamples, peekCurrentWindow, removeEntities, removeEntityGroup, retainEntities, retainEntityGroup
generation
public KafkaBrokerMetricSampleAggregator(KafkaCruiseControlConfig config)
config
- The load monitor configurations.public MetricSampleAggregationResult<BrokerEntity> aggregate(Set<BrokerEntity> brokerEntities)
brokerEntities
- the set of brokers to aggregate.