[FLINK-672] Make Aggregate transformation use combinable Reduce

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: pre-apache-0.5, pre-apache
• Labels: github-import
• Assignee: Stephan Ewen
• Reporter: GitHub Import
• Created: 09/Jun/14 12:44
• Updated: 18/Jun/14 15:49
• Resolved: 18/Jun/14 15:49

Description

The current implementation of the Aggregate transformation compiles to a non-combinable GroupReduce.

Many aggregation functions can be implemented more efficiently using combinable Reduce operators.

---------------- Imported from GitHub ----------------
Url: https://github.com/stratosphere/stratosphere/issues/672
Created by: fhueske
Labels: enhancement, java api,
Milestone: Release 0.6 (unplanned)
Created at: Wed Apr 09 21:13:41 CEST 2014
State: open