Package 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.

Field Summary

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

stat, unit

Constructor Summary

Constructors

Constructor	Description
SimpleRate()

Method Summary

Modifier and Type	Method	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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

SimpleRate

public SimpleRate()

Method Details

windowSize

public long windowSize(MetricConfig config,
 long now)

Overrides:

windowSize in class Rate