[ https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137209#comment-15137209 ]
ASF GitHub Bot commented on FLINK-2991: --------------------------------------- GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1605 [FLINK-2991] Add Folding State and use in WindowOperator This enables efficient incremental aggregation of fold window. This also adds: - WindowedStream.apply(initVal, foldFunction, windowFunction) - AllWindowedStream.apply(initVal, foldFunction, windowFunction) You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink window-fold Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/1605.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1605 ---- commit f81df7039455eb1ae4834490a79aa6577635eda4 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-02-08T13:56:19Z [FLINK-2991] Add Folding State and use in WindowOperator This enables efficient incremental aggregation of fold window. This also adds: - WindowedStream.apply(initVal, foldFunction, windowFunction) - AllWindowedStream.apply(initVal, foldFunction, windowFunction) ---- > Extend Window Operators to Allow Efficient Fold Operation > --------------------------------------------------------- > > Key: FLINK-2991 > URL: https://issues.apache.org/jira/browse/FLINK-2991 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > > Right now, a window fold is implemented as a WindowFunction that gets all the > elements as input. No pre-aggregation is performed. The window operator > should be extended to also allow the fold to also be pre-aggregated. > This requires changing the signature of the {{WindowBuffer}} so that it can > emit a type other than the input type. -- This message was sent by Atlassian JIRA (v6.3.4#6332)