Hi Filipa,

Yes, you could have a separate stream per id and have a separate windowed bolt 
subscribe to the corresponding stream.

The other option is to do the id based grouping  within the windowed bolt each 
time its "execute" method is triggered with the tuples in the current window.

Thanks,
Arun

From:  Filipa Duarte
Reply-To:  "[email protected]"
Date:  Friday, April 1, 2016 at 10:47 PM
To:  "[email protected]"
Subject:  Storm 1.0.0 Windowing by id 

Hi!

 

With regard to the new windowing features of Storm 1.0.0, is it possible to 
group the windows by  id, so that the events coming from different clients are 
processed by different windows?

Thank you.


Regards,

Filipa

 

Reply via email to