I am still not able to get much after reading the stuff. Please help with some basic code to start to build this window and trigger.
Another option I am thinking is I just use a Richflatmap function and use the keyed state to build this logic. Is that the correct approach? On Fri, May 22, 2020 at 4:52 PM aj <ajainje...@gmail.com> wrote: > > > 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/> > -- Thanks & Regards, Anuj Jain Mob. : +91- 8588817877 Skype : anuj.jain07 <http://www.oracle.com/> <http://www.cse.iitm.ac.in/%7Eanujjain/>
