Class Rate

java.lang.Object
org.apache.kafka.common.metrics.stats.Rate
All Implemented Interfaces:
Measurable, MeasurableStat, MetricValueProvider<Double>, Stat
Direct Known Subclasses:
SimpleRate
public class Rateextends Object implements MeasurableStat
The rate of the given quantity. By default this is the total observed over a set of samples from a sampled statistic divided by the elapsed time over the sample windows. Alternative SampledStat implementations can be provided, however, to record the rate of occurrences (e.g. the count of values measured over the time interval) or other such values.

  • Constructor Details

  • Method Details

    • unitName

      public String unitName()

    • 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
      Parameters:
      config - The configuration to use for this metric
      value - The value to record
      timeMs - The POSIX time in milliseconds this value occurred

    • measure

      public double measure(MetricConfig config, long now)
      Description copied from interface: Measurable
      Measure this quantity and return the result as a double.
      Specified by:
      measure in interface Measurable
      Parameters:
      config - The configuration for this metric
      now - The POSIX time in milliseconds the measurement is being taken
      Returns:
      The measured value

    • windowSize

      public long windowSize(MetricConfig config, long now)

    • toString

      public String toString()
      Overrides:
      toString in class Object