Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
BatchTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
<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. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironmentImpl.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction) |
Modifier and Type | Method and Description |
---|---|
AggregateFunction<?,?> |
AggregateFunctionDefinition.getAggregateFunction() |
Constructor and Description |
---|
AggregateFunctionDefinition(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo) |
Modifier and Type | Class and Description |
---|---|
class |
HiveGenericUDAF
|
Modifier and Type | Class and Description |
---|---|
class |
PythonAggregateFunction
The wrapper of user defined python aggregate function.
|
Modifier and Type | Class and Description |
---|---|
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 |
InternalAggregateFunction<T,ACC>
Base class for fully resolved and strongly typed
AggregateFunction s provided by AggFunctionFactory . |
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.
|
Modifier and Type | Method and Description |
---|---|
AggregateFunction |
HiveAggSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
Constructor and Description |
---|
HiveAggSqlFunction(FunctionIdentifier identifier,
AggregateFunction aggregateFunction,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static TypeInference |
TypeInferenceExtractor.forAggregateFunction(DataTypeFactory typeFactory,
Class<? extends AggregateFunction<?,?>> function)
Extracts a type inference from a
AggregateFunction . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.