flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1244) setCombinable() clunky to use
Date Fri, 14 Nov 2014 12:34:33 GMT
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)

Mime
View raw message