@PublicEvolving public interface FlatAggregateTable
Modifier and Type | Method and Description |
---|---|
Table |
select(Expression... fields)
Performs a selection operation on a FlatAggregateTable table.
|
Table |
select(String fields)
Performs a selection operation on a FlatAggregateTable.
|
Table select(String fields)
Note: You have to close the flatAggregate with a select statement. And the select statement does not support aggregate functions.
Example:
TableAggregateFunction tableAggFunc = new MyTableAggregateFunction
tableEnv.registerFunction("tableAggFunc", tableAggFunc);
tab.groupBy("key")
.flatAggregate("tableAggFunc(a, b) as (x, y, z)")
.select("key, x, y, z")
Table select(Expression... fields)
Note: You have to close the flatAggregate with a select statement. And the select statement does not support aggregate functions.
Scala Example:
val tableAggFunc = new MyTableAggregateFunction
tab.groupBy('key)
.flatAggregate(tableAggFunc('a, 'b) as ('x, 'y, 'z))
.select('key, 'x, 'y, 'z)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.