SpecsModelExploreRequirements
SpecsModelExploreRequirements
Window Aggregator
Overview
Guide
Twin streams
Links and Communications
IDproduct.processing.stream_processor.window_aggregator
DescriptionComputes tumbling / sliding aggregations.
Keywindow_aggregator
Typecomponent
Statusactive
TeamStream Processing
Owner
stream-processing@iotgateway.example
TechnologiesJava, Apache Flink
Tags
Table of contents
Guide
Window Aggregator
Window types
Outputs
Links and Communications
Requirements

Attributes

parallelism64
window1m tumbling

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.

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.

Links and Communications

1 incoming link · 1 outgoing link

Incoming Links(1)

Source objectLabelLink typeRelationRaw idRequiredDescription
Anomaly Detector

example-iot.product.processing.stream_processor.anomaly_detector

component
detects anomalies in—linksproduct.processing.stream_processor.window_aggregator——

Outgoing Links(1)

Target objectLabelLink typeRelationRaw idRequiredDescription
Kafka Consumer

example-iot.product.processing.stream_processor.kafka_consumer

component
aggregates stream from—linksproduct.processing.stream_processor.kafka_consumer——

Requirements