@PublicEvolving public interface WindowGroupedTable
GroupWindow
s.Modifier and Type | Method and Description |
---|---|
AggregatedTable |
aggregate(Expression aggregateFunction)
Performs an aggregate operation on a window grouped table.
|
AggregatedTable |
aggregate(String aggregateFunction)
Performs an aggregate operation on a window grouped table.
|
FlatAggregateTable |
flatAggregate(Expression tableAggregateFunction)
Performs a flatAggregate operation on a window grouped table.
|
FlatAggregateTable |
flatAggregate(String tableAggregateFunction)
Performs a flatAggregate operation on a window grouped table.
|
Table |
select(Expression... fields)
Performs a selection operation on a window grouped table.
|
Table |
select(String fields)
Performs a selection operation on a window grouped table.
|
Table select(String fields)
Example:
windowGroupedTable.select("key, window.start, value.avg as valavg")
Table select(Expression... fields)
Scala Example:
windowGroupedTable.select('key, 'window.start, 'value.avg as 'valavg)
AggregatedTable aggregate(String aggregateFunction)
aggregate(String)
with a select statement. The output will be flattened if the
output type is a composite type.
Example:
AggregateFunction aggFunc = new MyAggregateFunction();
tableEnv.registerFunction("aggFunc", aggFunc);
windowGroupedTable
.aggregate("aggFunc(a, b) as (x, y, z)")
.select("key, window.start, x, y, z")
AggregatedTable aggregate(Expression aggregateFunction)
aggregate(Expression)
with a select statement. The output will be flattened if the
output type is a composite type.
Scala Example:
val aggFunc = new MyAggregateFunction
windowGroupedTable
.aggregate(aggFunc('a, 'b) as ('x, 'y, 'z))
.select('key, 'window.start, 'x, 'y, 'z)
FlatAggregateTable flatAggregate(String tableAggregateFunction)
Example:
TableAggregateFunction tableAggFunc = new MyTableAggregateFunction();
tableEnv.registerFunction("tableAggFunc", tableAggFunc);
windowGroupedTable
.flatAggregate("tableAggFunc(a, b) as (x, y, z)")
.select("key, window.start, x, y, z")
FlatAggregateTable flatAggregate(Expression tableAggregateFunction)
Scala Example:
val tableAggFunc = new MyTableAggregateFunction
windowGroupedTable
.flatAggregate(tableAggFunc('a, 'b) as ('x, 'y, 'z))
.select('key, 'window.start, 'x, 'y, 'z)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.