Data Stream Processing Challenge
Data Stream Processing Challenge
Build real-time filter, map, and window pipelines
Interactive game
Stream processing
Data Stream Processing Challenge
Build real-time filter, map, and window pipelines that transform raw IoT readings into the expected output.
8Scenarios
3Rule types
18 minEstimated time
Try
For scenario 1, select a window, event-time policy, and state strategy before Check.
Observe
Latest shifts from 0/30 as latency, late-event handling, and aggregate correctness meet the fixture's stream requirement.
Explain
The scoring fixtures simplify one stream at a time; they omit partition skew, watermark idleness, state-store limits, checkpoint failure, backpressure, retractions, and processing guarantees.
Technical boundaries. The game executes deterministic teaching events and simplified operators. It does not simulate distributed partitions, watermark lag, backpressure, checkpoint recovery, duplicate delivery, schema evolution, or production throughput.
Progress
Scenario 1 of 8
0Score
0Rules
0Latest
Loading stream-processing scenarios...
Reference Material
Loading stream-processing notes...