[jira] [Closed] (FLINK-672) Make Aggregate transformation use combinable Reduce

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Closed] (FLINK-672) Make Aggregate transformation use combinable Reduce

Shang Yuanchun (Jira)

     [ https://issues.apache.org/jira/browse/FLINK-672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger closed FLINK-672.
--------------------------------

       Resolution: Fixed
    Fix Version/s: pre-apache-0.5
         Assignee: Stephan Ewen

This issue has been resolved with this commit: https://github.com/apache/incubator-flink/commit/f834e7d3287f377798ad8b7d13058b5499cdf0db

> Make Aggregate transformation use combinable Reduce
> ---------------------------------------------------
>
>                 Key: FLINK-672
>                 URL: https://issues.apache.org/jira/browse/FLINK-672
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: GitHub Import
>            Assignee: Stephan Ewen
>              Labels: github-import
>             Fix For: pre-apache, pre-apache-0.5
>
>
> 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|https://github.com/fhueske]
> Labels: enhancement, java api,
> Milestone: Release 0.6 (unplanned)
> Created at: Wed Apr 09 21:13:41 CEST 2014
> State: open



--
This message was sent by Atlassian JIRA
(v6.2#6252)