Collected sources and patterns will appear here. Add from search, explore, or the patterns library.
Stream<LateEvent> -> Stream<CorrectionDelta>
Recompute downstream aggregations and emit corrective updates when late-arriving or out-of-order stream events are received.
Problem it solves
Out-of-order data arrival in stream processing leads to inaccurate calculations if historical states are not retroactively corrected.
Consumes
Emits
The real projects this mechanism was found in. Attribution is the point — this is how the best teams actually do it.