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

Packages that use ImperativeAggregateFunction

Package	Description
org.apache.flink.table.catalog
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

Uses of ImperativeAggregateFunction in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog with parameters of type ImperativeAggregateFunction

Modifier and Type	Method and Description
<T,ACC> void	FunctionCatalog.registerTempSystemAggregateFunction(String name, ImperativeAggregateFunction<T,ACC> function, TypeInformation<T> resultType, TypeInformation<ACC> accType) Deprecated. Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.

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

Subclasses of ImperativeAggregateFunction 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 ImperativeAggregateFunction in org.apache.flink.table.functions

Subclasses of ImperativeAggregateFunction in org.apache.flink.table.functions

Modifier and Type	Class and Description
class	AggregateFunction<T,ACC> Base class for a user-defined aggregate function.
class	TableAggregateFunction<T,ACC> Base class for a user-defined table aggregate function.

Methods in org.apache.flink.table.functions with parameters of type ImperativeAggregateFunction

Modifier and Type	Method and Description
static <T,ACC> TypeInformation<ACC>	UserDefinedFunctionHelper.getAccumulatorTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
static <T,ACC> TypeInformation<ACC>	UserDefinedFunctionHelper.getAccumulatorTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction, TypeInformation<ACC> scalaType) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
static <T,ACC> TypeInformation<T>	UserDefinedFunctionHelper.getReturnTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
static <T,ACC> TypeInformation<T>	UserDefinedFunctionHelper.getReturnTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction, TypeInformation<T> scalaType) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.

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

Subclasses of ImperativeAggregateFunction 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 ImperativeAggregateFunction in org.apache.flink.table.functions.python

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

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

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

Subclasses of ImperativeAggregateFunction 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 ImperativeAggregateFunction in org.apache.flink.table.toolbox

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

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