US 12,411,706 B2
Reconciliation systems and methods for unbounded streams
Duncan Stewart, London (GB); and Alok Dwivedi, Reading (GB)
Assigned to Capital One Financial Corporation, McLean, VA (US)
Filed by Capital One Financial Corporation, McLean, VA (US)
Filed on Aug. 10, 2022, as Appl. No. 17/884,857.
Prior Publication US 2024/0053999 A1, Feb. 15, 2024
Int. Cl. G06F 9/455 (2018.01); H04L 9/40 (2022.01)
CPC G06F 9/45558 (2013.01) [H04L 63/12 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A computing system comprising:
a network interface for communicating over at least one data network;
at least one processor;
at least one non-transitory computer-readable medium; and
program instructions stored on the at least one non-transitory computer-readable medium that are executable by the at least one processor such that the computing system is configured to:
detect a window open sentinel for a window within an unbounded stream of events, wherein the window open sentinel indicates one or more reconciliation rules for the window;
detect a shard open sentinel for a shard within the window, wherein the shard open sentinel indicates one or more reconciliation rules for the shard;
receive a set of events produced within the shard;
detect a shard close sentinel for the shard, wherein the shard close sentinel includes an indication of one or more producer-generated reconciliation attributes for the shard;
execute the one or more reconciliation rules for the shard for a set of events produced within the shard to thereby generate one or more consumer-generated reconciliation attributes for the shard;
based on detecting the shard close sentinel, reconcile the one or more consumer-generated reconciliation attributes for the shard against the one or more producer-generated reconciliation attributes for the shard;
detect a window close sentinel, wherein the window close sentinel includes an indication of one or more producer-generated reconciliation attributes for the window;
execute the one or more reconciliation rules for the window for a set of events produced within the window to thereby generate one or more consumer-generated reconciliation attributes for the window; and
based on detecting the window close sentinel, reconcile the one or more consumer-generated reconciliation attributes for the window against the one or more producer-generated reconciliation attributes for the window.