[jira] [Created] (FLINK-1509) Streaming Group Reduce Combiner

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

[jira] [Created] (FLINK-1509) Streaming Group Reduce Combiner

Shang Yuanchun (Jira)
Fabian Hueske created FLINK-1509:
------------------------------------

             Summary: Streaming Group Reduce Combiner
                 Key: FLINK-1509
                 URL: https://issues.apache.org/jira/browse/FLINK-1509
             Project: Flink
          Issue Type: New Feature
          Components: Local Runtime, Optimizer
            Reporter: Fabian Hueske
            Priority: Minor


Combiners for GroupReduce operators are currently always (partially) sorting their input even if the data is already appropriately sorted.

It should be relatively easy to add chained and unchained implementations of a streaming group reduce combiner strategy .



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)