Package org.apache.flink.api.common.accumulators

Interface Summary

Interface	Description
Accumulator<V,R extends Serializable>	Accumulators collect distributed statistics or aggregates in a from user functions and operators.
SimpleAccumulator<T extends Serializable>	Similar to Accumulator, but the type of items to add and the result value must be the same.

Class Summary

Class	Description
AccumulatorHelper	Helper functions for the interaction with Accumulator.
AverageAccumulator	An accumulator that computes the average value.
DoubleCounter	An accumulator that sums up double values.
DoubleMaximum	An accumulator that finds the maximum double value.
DoubleMinimum	An accumulator that finds the minimum double value.
Histogram	Histogram accumulator, which builds a histogram in a distributed manner.
IntCounter	An accumulator that sums up Integer values.
IntMaximum	An accumulator that finds the maximum integer value.
IntMinimum	An accumulator that finds the minimum integer value.
ListAccumulator<T>	This accumulator stores a collection of objects.
LongCounter	An accumulator that sums up long values.
LongMaximum	An accumulator that finds the maximum long value.
LongMinimum	An accumulator that finds the minimum long value.
SerializedListAccumulator<T>	This accumulator stores a collection of objects in serialized form, so that the stored objects are not affected by modifications to the original objects.