Re: CountTrigger FIRE or FIRE_AND_PURGE

2016-09-01 Thread Fabian Hueske
gt; > ------ > *From:* Fabian Hueske > *Sent:* Monday, August 29, 2016 5:46:06 PM > *To:* user@flink.apache.org > *Subject:* Re: CountTrigger FIRE or FIRE_AND_PURGE > > Hi Paul, > > This blog post [1] includes an example of an early trigger that sho

Re: CountTrigger FIRE or FIRE_AND_PURGE

2016-08-30 Thread Paul Joireman
e: CountTrigger FIRE or FIRE_AND_PURGE Hi Paul, This blog post [1] includes an example of an early trigger that should pretty much do what you are looking for. This one [2] explains the windowing mechanics of Flink (window assigner, trigger, function, etc). Hope this helps, Fabian [1] https://ww

Re: CountTrigger FIRE or FIRE_AND_PURGE

2016-08-29 Thread Fabian Hueske
Hi Paul, This blog post [1] includes an example of an early trigger that should pretty much do what you are looking for. This one [2] explains the windowing mechanics of Flink (window assigner, trigger, function, etc). Hope this helps, Fabian [1] https://www.mapr.com/blog/essential-guide-streami