flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-970) Implement a first(n) operator
Date Tue, 24 Jun 2014 08:37:24 GMT
Timo Walther created FLINK-970:

             Summary: Implement a first(n) operator
                 Key: FLINK-970
                 URL: https://issues.apache.org/jira/browse/FLINK-970
             Project: Flink
          Issue Type: New Feature
            Reporter: Timo Walther
            Assignee: Timo Walther
            Priority: Minor

It is only syntactic sugar, but I had many cases where I just needed the first element  or
the first 2 elements in a GroupReduce.

E.g. Instead of

.reduceGroup(new GroupReduceFunction<String, String>() {
					public void reduce(Iterator<String> values, Collector<String> out) throws
Exception {


This message was sent by Atlassian JIRA

View raw message