HomeArenaGraphSignalTopics

/ The Arena

Prove your engineering skills.

GLOBAL+50 XP

Build a Stateful Sliding Window Stream Processing Aggregator

Problem Overview

Stream processing engines compute sliding window aggregates by maintaining intermediate state and evaluating closed windows as the event-time watermark advances.

In this landmark capstone, you will implement:

  1. Sliding Window Ingestion: Map incoming timestamped events to overlapping window buckets.
  2. Watermark Trigger Evaluation: Compute closed window aggregates (SUM & COUNT) strictly when watermark >= windowEnd.

Join The Arena

Create an account to submit your implementation, test against our containerized CI suite, and climb the global leaderboard.

Create Account

ALREADY HAVE AN ACCOUNT? LOG IN