Reconciliation systems and methods for unbounded streams

A non-transitory computer-readable medium, wherein the non-transitory computer-readable medium is provisioned with program instructions that, when executed by at least one processor, cause a computing system to:

• determine a start of a window in an unbounded stream of events produced by the computing system;
• based on determining the start of the window, inject, into the unbounded stream of events, a window open sentinel that indicates one or more reconciliation rules for the window;
• transmit a set of events produced within the window;
• execute the one or more reconciliation rules for the window for the set of events produced within the window to thereby generate one or more reconciliation attributes for the window;
• determine a close of the window in the unbounded stream of events;
• and
• based on determining the close of the window, inject, into the unbounded stream of events, a window close sentinel that indicates the one or more reconciliation attributes for the window.

A method carried out by a computing system, the method comprising:

• determining a start of a window in an unbounded stream of events produced by the computing system;
• based on determining the start of the window, injecting, into the unbounded stream of events, a window open sentinel that indicates one or more reconciliation rules for the window;
• transmitting a set of events produced within the window;
• executing the one or more reconciliation rules for the window for the set of events produced within the window to thereby generate one or more reconciliation attributes for the window;
• determining a close of the window in the unbounded stream of events;
• and
• based on determining the close of the window, injecting, into the unbounded stream of events, a window close sentinel that indicates the one or more reconciliation attributes for the window.