Skip to main content
Version: 0.91.0

Aggregation


Description

Performs different aggregation functions based on a sliding time window (e.g., average, sum, min, max)


Required input

The aggregation processor requires a data stream that has at least one field containing a numerical value.


Configuration

Group by

The aggregation function can be calculated separately (partitioned) by the selected field value.

Output every

The frequency in which aggregated values are sent in seconds.

Time window

The size of the time window in seconds

Aggregated Value

The field used for calculating the aggregation value.

Output

This processor appends the latest aggregated value to every input event that arrives.