Hi, simpleusr Maybe custom trigger[1] can be helpful.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/windows.html#triggers Best, Congxian On Feb 15, 2019, 13:15 +0800, simpleusr <ceyhanka...@gmail.com>, wrote: > Hi, > > My ultimate requirement is to stop processing of certain events between > 00:00:00 and 01:00:00 for each day (Time is in HH:mm:SS format). > > I am flink newbie and I thought only option to delay elements is to collect > them in a window between 00:00:00 and 01:00:00 for each day. > > TumblingEventTimeWindows for one hour seems the possible candidate but as I > understand this window will be present for all times, i.e (startTime, > startTime+1hour), (startTime+1hour, startTime+2hour), (startTime+2hour, > startTime+3hour)... > > How will it be possible to start a window at 00:00:00 each day and stop the > window at 01:00:00? > > Or is there any other option to keep elements in the job between 00:00:00 > and 01:00:00 and then start to process them after 01:00:00? > > Best regards > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
