org.apache.flink.runtime.checkpoint

Class StatsSummary

java.lang.Object

org.apache.flink.runtime.checkpoint.StatsSummary

All Implemented Interfaces:

Serializable

public class StatsSummary
extends Object
implements Serializable

Aggregated values of some measurement such as min/max/average state size. Used in reporting checkpoint statistics.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
StatsSummarySnapshot	createSnapshot() Returns a snapshot of the current state.
long	getAverage() Calculates the average over all seen values.
long	getCount() Returns the count of all seen values.
long	getMaximum() Returns the maximum seen value.
long	getMinimum() Returns the minimum seen value.
long	getSum() Returns the sum of all seen values.

Methods inherited from class java.lang.Object

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

Method Detail

createSnapshot

public StatsSummarySnapshot createSnapshot()

Returns a snapshot of the current state.

Returns:

A snapshot of the current state.

getMinimum

public long getMinimum()

Returns the minimum seen value.

Returns:

The current minimum value.

getMaximum

public long getMaximum()

Returns the maximum seen value.

Returns:

The current maximum value.

getSum

public long getSum()

Returns the sum of all seen values.

Returns:

Sum of all values.

getCount

public long getCount()

Returns the count of all seen values.

Returns:

Count of all values.

getAverage

public long getAverage()

Calculates the average over all seen values.

Returns:

Average over all seen values.