Package org.apache.flink.api.java.aggregation
-
Interface Summary Interface Description AggregationFunctionFactory Interface of factory for creatingAggregationFunction. -
Class Summary Class Description AggregationFunction<T> MaxAggregationFunction<T extends Comparable<T>> Implementation ofAggregationFunctionfor max operation.MaxAggregationFunction.MaxAggregationFunctionFactory Factory forMaxAggregationFunction.MinAggregationFunction<T extends Comparable<T>> Implementations ofAggregationFunctionfor min operation.MinAggregationFunction.MinAggregationFunctionFactory Factory forMinAggregationFunction.SumAggregationFunction<T> Definitions of sum functions for different numerical types.SumAggregationFunction.SumAggregationFunctionFactory Factory forSumAggregationFunction. -
Enum Summary Enum Description Aggregations Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. -
Exception Summary Exception Description UnsupportedAggregationTypeException Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.