[
https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14361683#comment-14361683
]
ASF GitHub Bot commented on FLINK-1450:
---------------------------------------
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/481#issuecomment-80195717
I added some other minor comments :)
Also if you are interested in taking this one step further there are some
possibilities (after I merged this):
- add combiners/aggregators (that basically make it possible to apply
folds in parallel by using ReduceFunctions), this is mostly applicable for
windowing
- add window PreAggregators for fold operators as well -> even better if
we have combiners
I will add some JIRA-s for these, but we should definitely sync on skype or
hangout if you decide to go further.
> Add Fold operator to the Streaming api
> --------------------------------------
>
> Key: FLINK-1450
> URL: https://issues.apache.org/jira/browse/FLINK-1450
> Project: Flink
> Issue Type: New Feature
> Components: Streaming
> Affects Versions: 0.9
> Reporter: Gyula Fora
> Priority: Minor
> Labels: starter
>
> The streaming API currently doesn't support a fold operator.
> This operator would work as the foldLeft method in Scala. This would allow
> effective implementations in a lot of cases where a the simple reduce is
> inappropriate due to different return types.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
