Re: continous time triger

2016-01-27 Thread Brian Chhun
production, > or dissemination) by persons other than the intended recipient(s) is > prohibited. If you receive this e-mail in error, please notify the sender > by phone or email immediately and delete it! > > > > From: Brian Chhun [mailto:brian.ch...@getbraintree.com] > > Se

Re: continous time triger

2016-01-27 Thread Aljoscha Krettek
oduction, or dissemination) > by persons other than the intended recipient(s) is prohibited. If you receive > this e-mail in error, please notify the sender by phone or email immediately > and delete it! > > From: Brian Chhun [mailto:brian.ch...@getbraintree.com] > Sent: Tuesday, J

RE: continous time triger

2016-01-26 Thread Radu Tudoran
26, 2016 5:28 PM To: user@flink.apache.org Subject: Re: continous time triger For what it's worth, we have a trigger that fires once a day for a recurring calculation. When an element comes in, we set the trigger context's processing time timer to the exact millisecond of the desired

Re: continous time triger

2016-01-26 Thread Brian Chhun
For what it's worth, we have a trigger that fires once a day for a recurring calculation. When an element comes in, we set the trigger context's processing time timer to the exact millisecond of the desired time. The predefined triggers were useful to look at to achieve this: https://github.com/apa

Re: continous time triger

2016-01-26 Thread Till Rohrmann
Hi Radu, you can register processing and event time time triggers using the TriggerContext which is given to the onElement, onProcessingTime and onEventTime methods of Trigger. In case you register a processing time timer, the onProcessingTime method will be called once the system clock has passed