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

Class WindowedSum

java.lang.Object
org.apache.kafka.common.metrics.stats.SampledStat
org.apache.kafka.common.metrics.stats.WindowedSum
All Implemented Interfaces:
Measurable, MeasurableStat, MetricValueProvider<Double>, Stat
Direct Known Subclasses:
WindowedCount
public class WindowedSumextends SampledStat
A SampledStat that maintains the sum of what it has seen. This is a sampled version of CumulativeSum. See also WindowedCount if you want to increment the value by 1 on each recording.

  • Constructor Details

    • WindowedSum

      public WindowedSum()

  • Method Details

    • combine

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