Re: Clarification: use of AllWindowedStream.apply() function

amespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > > > > > -- > Software Technologist > http:/

Re: Clarification: use of AllWindowedStream.apply() function

Thanks, Aljoscha for the clarification. I understand that instead of using a flatMap() in the way I am using, I am better off using : * a fold (init, fold_func, window_func) first and then * map to a different type of my choice, inside the window_func, parameterised above I hope I am correct. If

Re: Clarification: use of AllWindowedStream.apply() function

Hi, you would indeed use apply(), or better fold(, , ) to map the result of folding your window to some other data type. If you will, a WindowFunction allows "mapping" the result of your windowing to a different type. Best, Aljoscha On Wed, 15 Feb 2017 at 06:14 nsengupta wrote: > I have gone th

Re: Clarification: use of AllWindowedStream.apply() function

I have gone through this post , where Aljoscha explains that /mapping/ on WindowedStream is /not/ allowed. So, I think I haven't asked the question properly. Here is (hopefully)