public class KafkaBrokerMetricSampleAggregator extends MetricSampleAggregator<BrokerEntity>
MetricSampleAggregator
MetricSampleAggregator.SampleType
identityEntityMap, latestInvalidWindowIndex, 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<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, windowIndicesToWindows, windowIndicesToWindows
generation
public KafkaBrokerMetricSampleAggregator(KafkaCruiseControlConfig config)
config
- The load monitor configurations.public MetricSampleAggregationResult<BrokerEntity> aggregate(Set<BrokerEntity> brokerEntities)
brokerEntities
- the set of brokers to aggregate.