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. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironmentImpl.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction) |
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. |
Modifier and Type | Method and Description |
---|---|
AggregateFunction<?,?> |
AggregateFunctionDefinition.getAggregateFunction()
Deprecated.
|
Constructor and Description |
---|
AggregateFunctionDefinition(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
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 | 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 | Class and Description |
---|---|
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
|
class |
JsonObjectAggFunction
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
CountAggFunction
Count agg aggregate.
|
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–2023 The Apache Software Foundation. All rights reserved.