[FLINK-12081] Introduce aggregation operator code generator to blink batch

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.9.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 02/Apr/19 09:23
• Updated: 08/Apr/19 03:21
• Resolved: 08/Apr/19 03:21

Description

1.Introduce aggregation code generator without keys.

2.Introduce sort aggregation code generator to deal with all aggregate functions with keys. (Require input in keys order.)

3.Introduce hash aggregation code generator to deal with DeclarativeAggregateFunction and aggregateBuffers can be update(e.g.: setInt) in BinaryRow. (Hash Aggregate performs much better than Sort Aggregate)

Issue Links

• is a child of: FLINK-11490 Add an initial Blink SQL batch runtime
• links to: GitHub Pull Request #8099