Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironment.registerFunction(String name,
TableAggregateFunction<T,ACC> tableAggregateFunction)
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 TableAggregateFunction for more information on the new function
design. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironmentImpl.registerFunction(String name,
TableAggregateFunction<T,ACC> tableAggregateFunction) |
Modifier and Type | Method and Description |
---|---|
TableAggregateFunction<?,?> |
TableAggregateFunctionDefinition.getTableAggregateFunction()
Deprecated.
|
Constructor and Description |
---|
TableAggregateFunctionDefinition(String name,
TableAggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonTableAggregateFunction
The wrapper of user defined python table aggregate function.
|
Modifier and Type | Method and Description |
---|---|
static TypeInference |
TypeInferenceExtractor.forTableAggregateFunction(DataTypeFactory typeFactory,
Class<? extends TableAggregateFunction<?,?>> function)
Extracts a type inference from a
TableAggregateFunction . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.