Package org.apache.kafka.common.metrics.stats

Class ExponentialWeightedAvg

java.lang.Object
org.apache.kafka.common.metrics.stats.SampledStat
org.apache.kafka.common.metrics.stats.Avg
org.apache.kafka.common.metrics.stats.ExponentialWeightedAvg
All Implemented Interfaces:
Measurable, MeasurableStat, MetricValueProvider<Double>, Stat
public class ExponentialWeightedAvgextends Avg
A SampledStat that maintains an exponentially weighted average over its samples. This is the same as an Exponential Moving Average for a fixed sample set

  • Constructor Details

    • ExponentialWeightedAvg

      public ExponentialWeightedAvg(double alpha)

  • Method Details

    • combine

      public double combine(List<org.apache.kafka.common.metrics.stats.SampledStat.Sample> samples, MetricConfig config, long now)
      Overrides:
      combine in class Avg