Package org.apache.flink.api.java.aggregation

Interface Summary

Interface	Description
AggregationFunctionFactory	Interface of factory for creating AggregationFunction.

Class Summary

Class	Description
AggregationFunction<T>
MaxAggregationFunction<T extends Comparable<T>>	Implementation of AggregationFunction for max operation.
MaxAggregationFunction.MaxAggregationFunctionFactory	Factory for MaxAggregationFunction.
MinAggregationFunction<T extends Comparable<T>>	Implementations of AggregationFunction for min operation.
MinAggregationFunction.MinAggregationFunctionFactory	Factory for MinAggregationFunction.
SumAggregationFunction<T>	Definitions of sum functions for different numerical types.
SumAggregationFunction.SumAggregationFunctionFactory	Factory for SumAggregationFunction.

Enum Summary

Enum	Description
Aggregations	Shortcuts for Aggregation factories.

Exception Summary

Exception	Description
UnsupportedAggregationTypeException	Exception indicating an unsupported type was used for an aggregation.