Re: Custom Trigger Implementation

Good to hear that! Kostas > On Apr 25, 2016, at 12:24 PM, Piyush Shrivastava > wrote: > > Thanks a lot Kostas. This solved my problem. > > Thanks and Regards, > Piyush Shrivastava > > http://webograffiti.com > > > On Monday, 25 A

Re: Custom Trigger Implementation

Thanks a lot Kostas. This solved my problem. Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Monday, 25 April 2016 3:27 PM, Kostas Kloudas wrote: Hi, Let me also add that you should also override the clear() method in order to clear you state.and delete the pending t

Re: Custom Trigger Implementation

Hi, Let me also add that you should also override the clear() method in order to clear you state. and delete the pending timers. Kostas > On Apr 25, 2016, at 11:52 AM, Kostas Kloudas > wrote: > > Hi Piyush, > > In the onElement function, you register a timer every time you receive an > ele

Re: Custom Trigger Implementation

Hi Piyush, In the onElement function, you register a timer every time you receive an element. When the next watermark arrives, in the flag==false case, this will lead to every element adding a timer for its timestamp+6ms. The same for flag==true case, with 2ms interval. What you can

Custom Trigger Implementation

Hi all,I want to implement a custom Trigger which fired a GlobalWindow in 1 minute for the first time and every 20 seconds after that.I believe I cannot get this logic right in the implementation of my custom Trigger. Please help me with this. Here is the code of my custom Trigger: public class