RE: Custom time window in Flink

2016-04-20 Thread Radu Tudoran
ibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it! From: Piyush Shrivastava [mailto:piyush...@yahoo.co.in] Sent: Wednesday, April 20, 2016 11:24 AM To: user@flink.apache.org Subject: Re: Custom time window in Flink Hello, Thanks

Re: Custom time window in Flink

2016-04-20 Thread Piyush Shrivastava
Hello,Thanks a lot for your reply. Can you share a sample code or example which I can refer while creating a custom evictor and trigger? Thanks and Regards,Piyush Shrivastava http://webograffiti.com On Wednesday, 20 April 2016 2:50 PM, Radu Tudoran wrote:

RE: Custom time window in Flink

2016-04-20 Thread Radu Tudoran
Hi, Tha way to do this is to create your own evictor. In the evictor you can than decide when the events are removed. I would suggest creating a symmetric trigger as well because I would assume that you also need to fire the computation first after 1 hour and then at each 5 minutes. The logic