Uses of Class
org.apache.flink.table.functions.AggregateFunction

Packages that use AggregateFunction

Package	Description
org.apache.flink.table.api.bridge.java
org.apache.flink.table.api.bridge.java.internal
org.apache.flink.table.examples.java.functions
org.apache.flink.table.functions
org.apache.flink.table.functions.hive
org.apache.flink.table.functions.python
org.apache.flink.table.runtime.functions.aggregate
org.apache.flink.table.toolbox
org.apache.flink.table.types.extraction

Uses of AggregateFunction in org.apache.flink.table.api.bridge.java

Methods in org.apache.flink.table.api.bridge.java with parameters of type AggregateFunction

Modifier and Type

Method and Description

<T,ACC> void

StreamTableEnvironment.registerFunction(String name, AggregateFunction<T,ACC> aggregateFunction) Deprecated. Use TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction) instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of AggregateFunction for more information on the new function design.

Uses of AggregateFunction in org.apache.flink.table.api.bridge.java.internal

Methods in org.apache.flink.table.api.bridge.java.internal with parameters of type AggregateFunction

Modifier and Type	Method and Description
<T,ACC> void	StreamTableEnvironmentImpl.registerFunction(String name, AggregateFunction<T,ACC> aggregateFunction)

Uses of AggregateFunction in org.apache.flink.table.examples.java.functions

Subclasses of AggregateFunction in org.apache.flink.table.examples.java.functions

Modifier and Type	Class and Description
class	LastDatedValueFunction<T> Implementation of an AggregateFunction that returns a row containing the latest non-null value with its corresponding date.

Uses of AggregateFunction in org.apache.flink.table.functions

Methods in org.apache.flink.table.functions that return AggregateFunction

Modifier and Type	Method and Description
AggregateFunction<?,?>	AggregateFunctionDefinition.getAggregateFunction() Deprecated.

Constructors in org.apache.flink.table.functions with parameters of type AggregateFunction

Constructor and Description
AggregateFunctionDefinition(String name, AggregateFunction<?,?> aggregateFunction, TypeInformation<?> resultTypeInfo, TypeInformation<?> accTypeInfo) Deprecated.

Uses of AggregateFunction in org.apache.flink.table.functions.hive

Subclasses of AggregateFunction in org.apache.flink.table.functions.hive

Modifier and Type	Class and Description
class	HiveGenericUDAF An AggregateFunction implementation that calls Hive's UDAF or GenericUDAFEvaluator.

Uses of AggregateFunction in org.apache.flink.table.functions.python

Subclasses of AggregateFunction in org.apache.flink.table.functions.python

Modifier and Type	Class and Description
class	PythonAggregateFunction The wrapper of user defined python aggregate function.

Uses of AggregateFunction in org.apache.flink.table.runtime.functions.aggregate

Subclasses of AggregateFunction in org.apache.flink.table.runtime.functions.aggregate

Modifier and Type	Class and Description
static class	BatchApproxCountDistinctAggFunctions.ApproxCountDistinctAggFunction<T> Base function for APPROX_COUNT_DISTINCT aggregate.
static class	BatchApproxCountDistinctAggFunctions.ByteApproxCountDistinctAggFunction Built-in byte APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DateApproxCountDistinctAggFunction Built-in Date APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DecimalApproxCountDistinctAggFunction Built-in decimal APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DoubleApproxCountDistinctAggFunction Built-in double APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.FloatApproxCountDistinctAggFunction Built-in float APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.IntApproxCountDistinctAggFunction Built-in int APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.LongApproxCountDistinctAggFunction Built-in long APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.ShortApproxCountDistinctAggFunction Built-in Short APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.StringApproxCountDistinctAggFunction Built-in string APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimeApproxCountDistinctAggFunction Built-in Time APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimestampApproxCountDistinctAggFunction Built-in Timestamp APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimestampLtzApproxCountDistinctAggFunction Built-in TimestampLtz APPROX_COUNT_DISTINCT aggregate function.
class	BuiltInAggregateFunction<T,ACC> Base class for runtime implementation represented as AggregateFunction that is constructed from SpecializedFunction.specialize(SpecializedContext).
class	CollectAggFunction<T> Built-in COLLECT aggregate function.
class	FirstValueAggFunction<T> Built-in FIRST_VALUE aggregate function.
class	FirstValueWithRetractAggFunction<T> Built-in FIRST_VALUE with retraction aggregate function.
class	JsonArrayAggFunction Implementation for BuiltInFunctionDefinitions.JSON_ARRAYAGG_ABSENT_ON_NULL / BuiltInFunctionDefinitions.JSON_ARRAYAGG_NULL_ON_NULL.
class	JsonObjectAggFunction Implementation for BuiltInFunctionDefinitions.JSON_OBJECTAGG_NULL_ON_NULL / BuiltInFunctionDefinitions.JSON_OBJECTAGG_ABSENT_ON_NULL.
class	LagAggFunction<T> Lag AggregateFunction.
class	LastValueAggFunction<T> Built-in LAST_VALUE aggregate function.
class	LastValueWithRetractAggFunction<T> Built-in LAST_VALUE with retraction aggregate function.
class	ListAggWithRetractAggFunction Built-in LISTAGG with retraction aggregate function.
class	ListAggWsWithRetractAggFunction Built-in LISTAGGWS with retraction aggregate function.
class	MaxWithRetractAggFunction<T extends Comparable<T>> Built-in MAX with retraction aggregate function.
class	MinWithRetractAggFunction<T extends Comparable<T>> Built-in MIN with retraction aggregate function.

Uses of AggregateFunction in org.apache.flink.table.toolbox

Subclasses of AggregateFunction in org.apache.flink.table.toolbox

Modifier and Type	Class and Description
class	CountAggFunction Count agg aggregate.

Uses of AggregateFunction in org.apache.flink.table.types.extraction

Method parameters in org.apache.flink.table.types.extraction with type arguments of type AggregateFunction

Modifier and Type	Method and Description
static TypeInference	TypeInferenceExtractor.forAggregateFunction(DataTypeFactory typeFactory, Class<? extends AggregateFunction<?,?>> function) Extracts a type inference from a AggregateFunction.