Re: Window elements for certain period for delayed processing

Many Thanks Fabian I will start to investigate ProcessFunction Regards -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Window elements for certain period for delayed processing

Hi, I would not use a window for that. Implementing the logic with a ProcessFunction seems more straight-forward. The function simply collects all events between 00:00 and 01:00 in a ListState and emits them when the time passes 01:00. All other records are simply forwarded. Best, Fabian Am Fr.,

Re: Window elements for certain period for delayed processing

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 , wrote: > Hi, > > My ultimate requirement is to stop processing of certain eve

Window elements for certain period for delayed processing

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. TumblingEventTime