org.apache.kafka.common.metrics.stats

Class CumulativeCount

java.lang.Object

org.apache.kafka.common.metrics.stats.CumulativeSum

org.apache.kafka.common.metrics.stats.CumulativeCount

All Implemented Interfaces:

Measurable, MeasurableStat, MetricValueProvider<Double>, Stat

public class CumulativeCount
extends CumulativeSum

A non-sampled version of WindowedCount maintained over all time. This is a special kind of CumulativeSum that always records 1 instead of the provided value. In other words, it counts the number of record(MetricConfig, double, long) invocations, instead of summing the recorded values.

Constructor Summary

Constructors

Constructor and Description
CumulativeCount()

Method Summary

Modifier and Type	Method and Description
void	record(MetricConfig config, double value, long timeMs) Record the given value

Methods inherited from class org.apache.kafka.common.metrics.stats.CumulativeSum

measure, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CumulativeCount

public CumulativeCount()

Method Detail

record

public void record(MetricConfig config,
                   double value,
                   long timeMs)

Description copied from interface: Stat

Record the given value

Specified by:

record in interface Stat

Overrides:

record in class CumulativeSum

Parameters:

config - The configuration to use for this metric

value - The value to record

timeMs - The POSIX time in milliseconds this value occurred