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<java.lang.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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.common.metrics.stats.Rate

Rate.SampledTotal

Field Summary

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

stat, unit

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, unitName

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleRate

public SimpleRate()

Method Detail

windowSize

public long windowSize(MetricConfig config,
                       long now)

Overrides:

windowSize in class Rate