[ https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16112702#comment-16112702 ]
ASF GitHub Bot commented on FLINK-5720: --------------------------------------- Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3816 Actually, `KeyedStream.aggregate` is protected and thus not accessible. You may, however, access `WindowedStream#aggregate(AggregateFunction<T,ACC,R>) ` and `AllWindowedStream#aggregate(AggregateFunction<T,ACC,R>) ` for windowed streams and use a stateful map or flatmap for the rest. > Deprecate "Folding" in all of DataStream API > -------------------------------------------- > > Key: FLINK-5720 > URL: https://issues.apache.org/jira/browse/FLINK-5720 > Project: Flink > Issue Type: Improvement > Components: DataStream API > Reporter: Aljoscha Krettek > Assignee: Chesnay Schepler > Priority: Blocker > Fix For: 1.3.0, 1.4.0 > > > Folding is an operation that cannot be done incrementally in a distributed > way and that also cannot be done on merging windows. Now that we have > {{AggregatingState}} and aggregate operations we should deprecate folding in > the APIs and deprecate {{FoldingState}}. > I suggest to remove folding completely in Flink 2.0 -- This message was sent by Atlassian JIRA (v6.4.14#64029)