sunjincheng created FLINK-11052: ----------------------------------- Summary: Add Bounded(Group Window) FlatAggregate operator to batch Table API Key: FLINK-11052 URL: https://issues.apache.org/jira/browse/FLINK-11052 Project: Flink Issue Type: Sub-task Components: Table API & SQL Reporter: sunjincheng Fix For: 1.8.0
Add FlatAggregate operator to *batch* group window Table API as described in [FLIP-29|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97552739]. The usage: {code:java} tab.window(Tumble/Session/Slide... as 'w) .groupBy('w, 'k1, 'k2) .flatAggregate(tableAggregate('a)) .select('w.rowtime, 'k1, 'k2, 'col1, 'col2) {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)