Performs different aggregation functions based on a sliding time window (e.g., average, sum, min, max)
The aggregation processor requires a data stream that has at least one field containing a numerical value.
The aaggregation function can be calculated separately (partitioned) by the selected field value.
The frequency in which aggregated values are sent in seconds.
The size of the time window in seconds
The field used for calculating the aggregation value.
This processor appends the latest aggregated value to every input event that arrives.