[FLINK-13473] Add GroupWindowed FlatAggregate support to stream Table API(blink planner), i.e, align with flink planner

• 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: pull-request-available
• Assignee: sunjincheng
• Reporter: sunjincheng
• Created: 29/Jul/19 12:41
• Updated: 12/Aug/19 14:44
• Resolved: 12/Aug/19 14:44

Description

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

Issue Links

• links to: GitHub Pull Request #9396