flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From madhairsilence <harish.kum...@tcs.com>
Subject Splitting input stream in to multiple windows and process individually
Date Thu, 13 Apr 2017 05:39:49 GMT
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-tp17010.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message