org.apache.flink.api.common.accumulators

Interface SimpleAccumulator<T extends Serializable>

All Superinterfaces:

Accumulator<T,T>, Cloneable, Serializable

All Known Implementing Classes:

AverageAccumulator, DoubleCounter, DoubleMaximum, DoubleMinimum, IntCounter, IntMaximum, IntMinimum, LongCounter, LongMaximum, LongMinimum, Utils.ChecksumHashCode

@Public
public interface SimpleAccumulator<T extends Serializable>
extends Accumulator<T,T>

Similar to Accumulator, but the type of items to add and the result value must be the same.

Method Summary

Methods inherited from interface org.apache.flink.api.common.accumulators.Accumulator

add, clone, getLocalValue, merge, resetLocal