-
Type:
Sub-task
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.10.0
-
Fix Version/s: 1.10.0
-
Component/s: Table SQL / Planner
-
Labels:
Add GroupWindowed FlatAggregate support to stream Table API(blink planner), i.e, align with flink planner.
The API looks like:
TableAggregateFunction tableAggFunc = new MyTableAggregateFunction(); tableEnv.registerFunction("tableAggFunc", tableAggFunc); windowGroupedTable .flatAggregate("tableAggFunc(a, b) as (x, y, z)") .select("key, window.start, x, y, z")
The detail can be found in Flip-29
- links to