Hortonworks Streaming Analytics Manager User Guide
Also available as:
PDF

Use Aggregate Functions over Windows

About This Task

Windowing is the ability to split an unbounded stream of data into finite sets based on specified criteria, such as time or count, so that you can perform aggregate functions (such as sum or average) on the bounded set of events. In SAM, you accomplish this using the Aggregate processor. The Aggregate processor supports two window types: tumbling and sliding. You can create a window based on time or count.

Steps

  1. Drag the Aggregate processor to the canvas and connect it to the stream application you are building.

  2. Double-click the Aggregate tile to configure it according the your stream application requirements.

Example