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

-archive.2336050.n4.nabble.com/Clarification- >> use-of-AllWindowedStream-apply-function-tp11627p11630.html >> Sent from the Apache Flink User Mailing List archive. mailing list >> archive at Nabble.com. >> > > > -- > If you reply to this ema

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)

Clarification: use of AllWindowedStream.apply() function

I am trying to understand if the AllWindowedStream.apply() function can be used for creating a DataStream of new types. Here is a portion of the code: case class RawMITSIMTupl