Using Aggregate Functions over Windows

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. SAM exposes these capabilities using the Aggregate processor. The Aggregate processor supports two window types, tumbling and sliding windows. The creation of a window can be based on time or count. The following images show how to use the Aggregate processor to implement Requirement 8 of the use case.

1. Drag the Aggregate processor to the canvas and connect it to the Rule processor.

   

2. Double-click on the Aggregate processor, and configure it to calculate the average speed of driver over a three-minute duration.