Questions / Quant development, Streaming market data
Align a consistent input cut
In a toy aligned checkpoint, input A’s barrier arrives first and A pauses; B continues until its matching barrier. During a 0.25-second wait, A’s source produces 800 records/s into an upstream buffer, with no previous backlog. How many A records accumulate?
Answer it in the app It's free. You get hints, a second try if you miss, and a follow-up question.
Show the answer and worked solution
Answer: 200 records
- The paused channel receives 800×0.25=200 new records. They lie after A’s barrier and are held outside the pre-barrier operator state.
Interview shortcut. Buffered = rate × wait = 800 × 0.25.
In the app this has a follow-up where one thing about the setup changes. Try the follow-up.