Re: apply with fold- and window function

2016-11-14 Thread Anchit Jatana
the aggregation task through fold function + element processing through window function. Hope this helps! Regards, Anchit -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/apply-with-fold-and-window-function-tp10092p10110.html Sent from

Re: apply with fold- and window function

2016-11-14 Thread Aljoscha Krettek
Hi, this is a known bug: https://issues.apache.org/jira/browse/FLINK-3869. I'm still hoping that we can get a workaround in for Flink 1.2. See my last comment in the Jira Issue. Cheers, Aljoscha On Mon, 14 Nov 2016 at 14:49 Stephan Epping wrote: > Hello, > > I

apply with fold- and window function

2016-11-14 Thread Stephan Epping
Hello, I wondered if there is a particular reason for the window function to have explicitly the same input/output type? public SingleOutputStreamOperator apply(R initialValue, FoldFunction foldFunction, WindowFunction function) for example (the following does not work):