Hi, You can either use trident topologies (see the manual) to process in batches or use storm's 'tick tuples' feature to aggregate using a defined time-window.
Hope this helped. On Mon, Aug 4, 2014 at 1:37 PM, padma priya chitturi <[email protected] > wrote: > Hi, > > I wanted to process streams in wondow of size say 'n' for every 't' sec. > Does storm has inbuilt API's which support such scenarios of handling > streams in a window ? > > Regards, > Padma Ch >
