Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
Add FlatAggregate operator to batch group window Table API as described in FLIP-29.
The usage:
tab.window(Tumble/Session/Slide... as 'w) .groupBy('w, 'k1, 'k2) .flatAggregate(tableAggregate('a)) .select('w.rowtime, 'k1, 'k2, 'col1, 'col2)