public class CumulativeCount
extends java.lang.Object
implements org.apache.kafka.common.metrics.MeasurableStat
Constructor and Description |
---|
CumulativeCount() |
Modifier and Type | Method and 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) |
public void record(org.apache.kafka.common.metrics.MetricConfig config, double value, long timeMs)
record
in interface org.apache.kafka.common.metrics.Stat
public double measure(org.apache.kafka.common.metrics.MetricConfig config, long now)
measure
in interface org.apache.kafka.common.metrics.Measurable