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
Drag the Aggregate processor to the canvas and connect it to the stream application you are building.
Double-click the Aggregate tile to configure it according the your stream application requirements.
Example
