[ https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139965#comment-15139965 ]
ASF GitHub Bot commented on FLINK-2991: --------------------------------------- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1605#issuecomment-182125713 You are adding new `.apply()` variants to the API which are not documented with the PR. > 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)