You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by padma priya chitturi <pa...@gmail.com> on 2014/08/04 12:37:55 UTC

Windowing queries on storm

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

Re: Windowing queries on storm

Posted by Andrew Xor <an...@gmail.com>.

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 <padmapriya30@gmail.com
> 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
>