[jira] [Created] (FLINK-1244) setCombinable() clunky to use

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

[jira] [Created] (FLINK-1244) setCombinable() clunky to use

Shang Yuanchun (Jira)
Chesnay Schepler created FLINK-1244:
---------------------------------------

             Summary: setCombinable() clunky to use
                 Key: FLINK-1244
                 URL: https://issues.apache.org/jira/browse/FLINK-1244
             Project: Flink
          Issue Type: Wish
          Components: Java API
            Reporter: Chesnay Schepler
            Priority: Trivial


Setting the combinable property for a GroupReduce manually is a bit clunky, since setCombinable() doesn't return the operator.

A wordcount would look like this:
{code:java}
GroupReduceOperator output = source
        .map...
        .groupBy(1)
        .reduceGroup...;
output.setCombinable(true);
output.print();
{code}

whereas this would be more convenient
{code:java}
source
        .map...
        .groupBy(1)
        .reduceGroup...
        .setCombinale(true)
        .print();
{code}

is there a reason for it not returning the operator?



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