org.apache.kafka.common.metrics.stats

Class SimpleRate

java.lang.Object

org.apache.kafka.common.metrics.stats.Rate

org.apache.kafka.common.metrics.stats.SimpleRate

All Implemented Interfaces:

Measurable, MeasurableStat, MetricValueProvider<Double>, Stat

public class SimpleRate
extends Rate

A simple rate the rate is incrementally calculated based on the elapsed time between the earliest reading and now. An exception is made for the first window, which is considered of fixed size. This avoids the issue of an artificially high rate when the gap between readings is close to 0.

Constructor Summary

Constructors

Constructor and Description
SimpleRate()

Method Summary

Modifier and Type	Method and Description
long	windowSize(MetricConfig config, long now)

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

measure, record, toString, unitName

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleRate

public SimpleRate()

Method Detail

windowSize

public long windowSize(MetricConfig config,
                       long now)

Overrides:

windowSize in class Rate