public class KafkaBrokerMetricSampleAggregator extends MetricSampleAggregator<java.lang.String,BrokerEntity>
MetricSampleAggregator
MetricSampleAggregator.SampleType
_identityEntityMap, _metricDef, _minSamplesPerWindow, _monitoringPeriodMs, _numWindows, _numWindowsToKeep, _sampleType, _windowMs
_generation
Constructor and Description |
---|
KafkaBrokerMetricSampleAggregator(KafkaCruiseControlConfig config)
Construct the metric sample aggregator.
|
Modifier and Type | Method and Description |
---|---|
MetricSampleAggregationResult<java.lang.String,BrokerEntity> |
aggregate(java.util.Set<BrokerEntity> brokerEntities)
Aggregate the metrics for the given brokers.
|
addSample, aggregate, allWindows, availableWindows, clear, completeness, earliestWindow, monitoringPeriodMs, numAvailableWindows, numAvailableWindows, numSamples, peekCurrentWindow, removeEntities, removeEntityGroup, retainEntities, retainEntityGroup
compareGeneration, compareGeneration, generation, setGeneration
public KafkaBrokerMetricSampleAggregator(KafkaCruiseControlConfig config)
config
- The load monitor configurations.public MetricSampleAggregationResult<java.lang.String,BrokerEntity> aggregate(java.util.Set<BrokerEntity> brokerEntities)
brokerEntities
- the set of brokers to aggregate.