Package | Description |
---|---|
org.apache.flink.table.api.java | |
org.apache.flink.table.api.java.internal | |
org.apache.flink.table.functions |
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) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.