Re: Filtering and mapping data after window opertator

Hi Soheil, We can't apply FilterFunction or MapFunction on WindowedStream. It is recommended to do these operations on DataStream, for example, temp.filter().map().keyBy(0).timeWindow(). Best, Hequn On Sat, Jul 14, 2018 at 9:14 PM, Soheil Pourbafrani wrote: > Hi, I'm getting data stream from a

Filtering and mapping data after window opertator

Hi, I'm getting data stream from a source and after gathering data in a time window I want to do some operation like filtering and mapping on windowed data, but the output of time window operation just allow reduce, aggregate or ... function and after that, I want to apply functions like filter or