Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironment.registerFunction(String name,
TableAggregateFunction<T,ACC> tableAggregateFunction)
Registers an
TableAggregateFunction under a unique name in the TableEnvironment's
catalog. |
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() |
Constructor and Description |
---|
TableAggregateFunctionDefinition(String name,
TableAggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo) |
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–2021 The Apache Software Foundation. All rights reserved.