Hi, that does not sound like a time window problem because there is not time-related condition to split the windows. I think you can implement that with a GlobalWindow and a custom trigger. The documentation about global windows, triggers, and evictors [1] and this blogpost [2] might be helpful
On thing that came to my mind reading your description, are you sure that the events arrive in the correct order? Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/windows.html [2] http://flink.apache.org/news/2015/12/04/Introducing-windows.html 2016-11-18 1:04 GMT+01:00 Abdul Salam Shaikh <abd.salam.sha...@gmail.com>: > Hi, > > I have a requirement for my thesis project where I need to set the time > window based on the value which I received in the event stream. > > I need to collect the values when the value starts at 0 and increments to > a max value(which is unknown) till the value resets to 0 again on which a > trigger is triggered which performs a calculation based on the values > collected. > > DataStream<Tuple4<String,Double,String,Integer>> detectorEventStream = > streamMatchedTuples > .keyBy(Based on the first param of the tuple) > .timeWindow(based on the second param of the tuple) > .apply(new PhaseCalculator()); > > I am relatively new in flink so I would like to have ideas on how to > proceed. > > -- > Thanks & Regards, > > *Abdul Salam Shaikh* > >
