I was also thinking to have a processing time window but that will not work for me. I want to start the window when the user "*search*" event arrives. So for each user window will start from the *search* event. The Tumbling window has fixed start end time so that will not be suitable in my case.
On Fri, May 22, 2020 at 10:23 AM Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > Hi, > > To achieve what you have in mind, I think what you have to do is to use a > processing time window of 30 mins, and have a custom trigger that matches > the "start" event in the `onElement` method and return > TriggerResult.FIRE_AND_PURGE. > > That way, the window fires either when the processing time has passed, or > the start event was recieved. > > Cheers, > Gordon > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ > -- Thanks & Regards, Anuj Jain Mob. : +91- 8588817877 Skype : anuj.jain07 <http://www.oracle.com/> <http://www.cse.iitm.ac.in/%7Eanujjain/>
