[
https://issues.apache.org/jira/browse/FLINK-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-622.
-------------------------------
Resolution: Duplicate
FLINK-758 has subsumed this issue. Actually, FLINK-758 kind of evolved to a
duplicate for this issue, but since the discussion happened there, I'm closing
this one.
Kudos to [~fhueske] for pointing this issue out earlier here.
> Allow Reduce function to specify a starting element.
> ----------------------------------------------------
>
> Key: FLINK-622
> URL: https://issues.apache.org/jira/browse/FLINK-622
> Project: Flink
> Issue Type: Improvement
> Reporter: GitHub Import
> Labels: github-import
> Fix For: pre-apache
>
>
> We could extend ```ReduceFunction``` by a method ```T getStartElement()```
> that returns the first element to give into the reduce function.
> By default this method returns ```null```. In this case, the first reduce
> call is done on the first and second elements of a group.
> If ```getStartElement()``` is overwritten in a ReduceFunction and it returns
> an object, the first reduce call is done on the start element and the first
> element.
> Right now, the Reduce function is only called if there are at least two
> elements in a group. Having the ```getStartElement()``` method, the UDF could
> also be called for groups with only one element.
> What do you guys think?
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/622
> Created by: [fhueske|https://github.com/fhueske]
> Labels: enhancement, java api, user satisfaction,
> Created at: Fri Mar 21 14:54:34 CET 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.2#6252)
