Two consumers read the same streaming aggregation

A medium Pipeline Design interview practice problem on DataDriven. Write and execute real pipeline design code with instant grading.

Domain

Pipeline Design

Difficulty

medium

Problem

Two consumers read the same streaming aggregation. The finance dashboard reports daily revenue and is audited monthly; reruns must produce identical history. The operations dashboard shows events-per-second the engine is processing and is used to detect lag. The section's rule is to name the consumer first, then the time domain: event time for finance (auditable, reproducible), processing time for operations (records what the engine saw). Pick the time domain on the canvas by splitting the existing aggregation into two transforms, one named for event-time bucketing feeding the finance consumer, one named for processing-time bucketing feeding the operations consumer.

Practice This Problem

Solve this Pipeline Design problem with real code execution. DataDriven runs your solution and grades it automatically.