Hello All,
I am getting a lot of user events in a stream. There are different types
of events, now I want to build some aggregation metrics for the user by
grouping events in buckets.
My condition for windowing is :
1. Start the window for the user when event_name: *"search" *arrived for
the user.
2. Trigger the window when
either 30 mins from the start of the window reached
OR
event_type : *"start" *is appeared.
After that, I want to do calculate some aggregation on those window events.
I know this can be done using process function but I am stuck to create the
window with multiple conditions trigger.
Please help me how to create this type of window with multiple
trigger condition either time or some event happen.
--
Thanks & Regards,
Anuj Jain
<http://www.cse.iitm.ac.in/%7Eanujjain/>
