[FLINK-10976] Add Aggregate operator to Table API

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: sunjincheng
• Created: 22/Nov/18 02:49
• Updated: 07/May/19 11:10
• Resolved: 07/May/19 11:10

Description

Add Aggregate operator to Table API as described in Google doc.

The usage:

val res = tab
 .groupBy('a) // leave out groupBy-clause to define global aggregates
 .agg(fun: AggregateFunction)  // output has columns 'a, 'b, 'c
 .select('a, 'c)

Issue Links

• links to: GitHub Pull Request #7235
• links to: GitHub Pull Request #8311