Re: Force triggering events on watermark

Yes, this should work. On Tue, 10 May 2016 at 19:01 Srikanth wrote: > Yes, will work. > I was trying another route of having a "finalize & purge trigger" that will >i) onElement - Register for event time watermark but not alter nested > trigger's TriggerResult > ii)

Re: Force triggering events on watermark

Yes, will work. I was trying another route of having a "finalize & purge trigger" that will i) onElement - Register for event time watermark but not alter nested trigger's TriggerResult ii) OnEventTime - Always purge after fire That will work with CountTrigger and other custom trigger too

Re: Force triggering events on watermark

Maybe the last example of this blog post is helpful [1]. Best, Fabian [1] https://www.mapr.com/blog/essential-guide-streaming-first-processing-apache-flink 2016-05-10 17:24 GMT+02:00 Srikanth : > Hi, > > I read the following in Flink doc "We can explicitly specify a

Force triggering events on watermark

Hi, I read the following in Flink doc "We can explicitly specify a Trigger to overwrite the default Trigger provided by the WindowAssigner. Note that specifying a triggers does not add an additional trigger condition but replaces the current trigger." So, I tested out the below code with count