Package org.apache.flink.runtime.metrics

Class DescriptiveStatisticsHistogram

java.lang.Object

org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogram

All Implemented Interfaces:

Serializable, Histogram, Metric

public class DescriptiveStatisticsHistogram
extends Object
implements Histogram, Serializable

The DescriptiveStatisticsHistogram use a DescriptiveStatistics DescriptiveStatistics as a Flink Histogram.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DescriptiveStatisticsHistogram(int windowSize)

Method Summary

Modifier and Type	Method	Description
long	getCount()	Get the count of seen elements.
HistogramStatistics	getStatistics()	Create statistics for the currently recorded elements.
void	update(long value)	Update the histogram with the given value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.metrics.Histogram

getMetricType

Constructor Detail

DescriptiveStatisticsHistogram

public DescriptiveStatisticsHistogram(int windowSize)

Method Detail

update

public void update(long value)

Description copied from interface: Histogram

Update the histogram with the given value.

Specified by:

update in interface Histogram

Parameters:

value - Value to update the histogram with

getCount

public long getCount()

Description copied from interface: Histogram

Get the count of seen elements.

Specified by:

getCount in interface Histogram

Returns:

Count of seen elements

getStatistics

public HistogramStatistics getStatistics()

Description copied from interface: Histogram

Create statistics for the currently recorded elements.

Specified by:

getStatistics in interface Histogram

Returns:

Statistics about the currently recorded elements