Package org.apache.flink.streaming.api.functions.aggregation

Class Summary

Class	Description
AggregationFunction<T>	Holder class for aggregation types that can be used on a windowed stream or keyed stream.
ComparableAggregator<T>	An AggregationFunction that computes values based on comparisons of Comparables.
Comparator	Internal comparator implementation, for use with ComparableAggregator.
SumAggregator<T>	An AggregationFunction that sums up fields.
SumFunction	Internal function for summing up contents of fields.

Enum Summary

Enum	Description
AggregationFunction.AggregationType	Aggregation types that can be used on a windowed stream or keyed stream.