| ID | product.processing.stream_processor.window_aggregator |
|---|---|
| Description | Computes tumbling / sliding aggregations. |
| Key | window_aggregator |
| Type | component |
| Team | Stream Processing |
| Owner | stream-processing@iotgateway.example |
| Status | active |
| Technologies | Java, Apache Flink |
| Attributes | parallelism: 64, window: 1m tumbling |
| Tags |
Table of contents
Guide
Window Aggregator
The Window Aggregator turns the raw event stream from the Kafka Consumer into compact, query-ready summaries. It maintains per-device windowed state and emits aggregates that feed both the query API and the Anomaly Detector.
Event time, not wall-clock
Aggregation is keyed on the event timestamp carried by each reading. A bounded watermark tolerates late and out-of-order arrivals so a slow device does not corrupt an already-closed window.