Two consumers read the same streaming aggregation
A medium Pipeline Design mock interview question on DataDriven. Practice with AI-powered feedback, real code execution, and a hire/no-hire decision.
- Domain
- Pipeline Design
- Difficulty
- medium
Interview Prompt
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.
How This Interview Works
- Read the vague prompt (just like a real interview)
- Ask clarifying questions to the AI interviewer
- Write your pipeline design solution with real code execution
- Get instant feedback and a hire/no-hire decision