Multi-stream: event time, arrival time and dropping late events

In a real feed an event's time and its arrival are two different numbers. A window can only close once, so anything arriving after the close plus the allowed lateness has to be dropped - and the code must say so rather than quietly counting it in the wrong bucket.

Full code & output

This topic is available to signed-in members.