Class CumulativeCount
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.metrics.CumulativeCount
-
- All Implemented Interfaces:
org.apache.kafka.common.metrics.Measurable
,org.apache.kafka.common.metrics.MeasurableStat
,org.apache.kafka.common.metrics.MetricValueProvider<java.lang.Double>
,org.apache.kafka.common.metrics.Stat
public class CumulativeCount extends java.lang.Object implements org.apache.kafka.common.metrics.MeasurableStat
A non-SampledStat version of Count for measuring -total metrics in streams
-
-
Constructor Summary
Constructors Constructor Description CumulativeCount()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description double
measure(org.apache.kafka.common.metrics.MetricConfig config, long now)
void
record(org.apache.kafka.common.metrics.MetricConfig config, double value, long timeMs)
-
-
-
Method Detail
-
record
public void record(org.apache.kafka.common.metrics.MetricConfig config, double value, long timeMs)
- Specified by:
record
in interfaceorg.apache.kafka.common.metrics.Stat
-
measure
public double measure(org.apache.kafka.common.metrics.MetricConfig config, long now)
- Specified by:
measure
in interfaceorg.apache.kafka.common.metrics.Measurable
-
-