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.

Window types

Fixed, non-overlapping 1-minute buckets. Used for the metrics surface where each point represents a discrete interval.

Outputs

count, min, max and avg per metric per window.
Emitted on window close (tumbling) or on each slide (sliding).
Keyed by device id so downstream consumers can join against twin metadata.

Window Aggregator

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.

Window types

Fixed, non-overlapping 1-minute buckets. Used for the metrics surface where each point represents a discrete interval.

Outputs

count, min, max and avg per metric per window.
Emitted on window close (tumbling) or on each slide (sliding).
Keyed by device id so downstream consumers can join against twin metadata.