Re: Splitting input stream in to multiple windows and process individually

2017-04-24 Thread Ufuk Celebi
keyBy("id").timeWindow(Time.hours(i)).apply(..); > } > > > > -- > View this message in context: > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Splitting-input-stream-in-to-multiple-windows-and-process-individually-tp17010.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com.

Splitting input stream in to multiple windows and process individually

2017-04-12 Thread madhairsilence
;).timeWindow(Time.hours(i)).apply(..); } -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Splitting-input-stream-in-to-multiple-windows-and-process-individually-tp17010.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Splitting input stream in to multiple windows and process individually

2017-04-12 Thread madhairsilence
yBy("id").timeWindow(Time.hours(i)).apply(..); } -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Splitting-input-stream-in-to-multiple-windows-and-process-individually-tp17009.html Sent from the Apache Flink Mailing List archive. mailing li