D8LooPFocus modeCODE WORKSPACE
Backfill replay window plan
Identify event partitions that need replay because late or corrected records arrived.
The SQL API will hydrate this workspace with the exercise-specific starter query and schema.
Sample input
source_eventsLate records arrive after their event day; corrections also force replay of the original event partition.
| event_id | event_time | ingested_at | is_correction |
|---|---|---|---|
| 501 | 2026-03-02 08:00:00 | 2026-03-02 08:01:00 | 0 |
| 502 | 2026-03-02 10:00:00 | 2026-03-05 09:00:00 | 0 |
| 503 | 2026-03-03 11:00:00 | 2026-03-05 10:00:00 | 1 |
| 505 | 2026-03-04 14:00:00 | 2026-03-06 02:00:00 | 0 |
Expected output
Expected outputReplay March 2, 3, and 4 because each has a late or corrected event.
| partition_day | records_to_replay | latest_arrival_at |
|---|---|---|
| 2026-03-02 | 1 | 2026-03-05 09:00:00 |
| 2026-03-03 | 1 | 2026-03-05 10:00:00 |
| 2026-03-04 | 1 | 2026-03-06 02:00:00 |
Constraints
Load the live SQL exercise to inspect the full prompt, schema, starter query, and expected output.
Expected skills
Backfills, Watermarks, Replay windows
SQL
Loading...
AI evaluation
Run the SQL query to inspect preview rows.