Apache Flink · Build your own · FLK-BYO
Build your own mini stream processor
- 10 h
- 8 stages
Build the real thing from scratch, one stage at a time. Each stage has its own tests, and you move on when it passes.
- 01Operator graph + push-based execution
- 02Keyed partitioning across workers
- 03Event time + watermarks (min across inputs)
- 04Tumbling/sliding windows with triggers
- 05Keyed state + timers (process functions)
- 06Checkpoint barriers (Chandy-Lamport / ABS)
- 07Recovery from a checkpoint with a replayable source
- 08Transactional (2PC) sink — end-to-end exactly-once
Run it locally
uv run de start FLK-BYO/01
uv run de test