Re: Questions about FoldFunction and WindowFunction

2016-11-02 Thread Aljoscha Krettek
cannot break API instability but right at the end of > this issue I'm proposing a different solution that we'll hopefully get in > for the next release. > > Cheers, > Aljoscha > > On Wed, 2 Nov 2016 at 10:42 Yassine MARZOUGUI > wrote: > > Hi all, > >

Re: Questions about FoldFunction and WindowFunction

2016-11-02 Thread Yassine MARZOUGUI
break API instability but right at the end of this issue I'm >> proposing a different solution that we'll hopefully get in for the next >> release. >> >> Cheers, >> Aljoscha >> >> On Wed, 2 Nov 2016 at 10:42 Yassine MARZOUGUI >> wrote: &

Re: Questions about FoldFunction and WindowFunction

2016-11-02 Thread Aljoscha Krettek
pefully get in > for the next release. > > Cheers, > Aljoscha > > On Wed, 2 Nov 2016 at 10:42 Yassine MARZOUGUI > wrote: > > Hi all, > > I have a couple questions about FoldFunction and WindowFunction: > > 1. When using a RichFoldFunction after a window as in

Re: Questions about FoldFunction and WindowFunction

2016-11-02 Thread Yassine MARZOUGUI
y but right at the end of this issue I'm > proposing a different solution that we'll hopefully get in for the next > release. > > Cheers, > Aljoscha > > On Wed, 2 Nov 2016 at 10:42 Yassine MARZOUGUI > wrote: > >> Hi all, >> >> I have a couple questions

Re: Questions about FoldFunction and WindowFunction

2016-11-02 Thread Aljoscha Krettek
016 at 10:42 Yassine MARZOUGUI wrote: > Hi all, > > I have a couple questions about FoldFunction and WindowFunction: > > 1. When using a RichFoldFunction after a window as in > keyedStream.window().fold(new > RichFoldFunction()), is the close() method called after each windo

Questions about FoldFunction and WindowFunction

2016-11-02 Thread Yassine MARZOUGUI
Hi all, I have a couple questions about FoldFunction and WindowFunction: 1. When using a RichFoldFunction after a window as in keyedStream.window().fold(new RichFoldFunction()), is the close() method called after each window or after all the windows for that key are fired? 2. When applying a