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

CountTrigger FIRE or FIRE_AND_PURGE

2016-08-29 Thread Paul Joireman
Hi all, I'm attempting to use long SlidingEventTime window (duration 24 hours) but I would like updates more frequently than the 24 hour length. I naeively attempted to use a simple CountTrigger(10) to give me the window every time 10 samples are collected, however, the window processing func