[FLINK-2237] Add hash-based Aggregation

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Won't Do
• Component/s: API / DataSet, Runtime / Task
• Assignee: Gábor Gévay
• Reporter: Rafiullah Momand
• Created: 17/Jun/15 18:23
• Updated: 02/Oct/19 17:44
• Resolved: 08/Jul/19 13:51

Description

Aggregation functions at the moment are implemented in a sort-based way.
How can we implement hash based Aggregation for Flink?

Issue Links

• is related to: FLINK-82 (Hash) Aggregators (fold style)

Sub-Tasks

• Add hash-based combine strategy for ReduceFunction: Closed
• Add hash-based strategy for CombineFunction: Closed
• Add hash-based strategy for ReduceFunction: Closed