You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by madhairsilence <ha...@tcs.com> on 2017/04/13 05:39:16 UTC

Splitting input stream in to multiple windows and process individually

down vote
favorite
I have a Datastream . I have to apply window function as 1 hour, 2 hour, 3
hour...24 hour. And each split has its own window function to be done

How do I split the window in an efficient way.

The dirtiest way I can think of is

for(int i=1; i < 24 ;i++){
   inputStream.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-tp17009.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.