Capital One Financial Corporation

Discover Financial Services LLC

Duncan Stewart

Alok Dwivedi

A computing system is configured to (i) detect a window open sentinel indicating one or more reconciliation rules for a window within an unbounded stream of events, (ii) detect a shard open sentinel indicating one or more reconciliation rules for the shard, (iii) receive a set of events produced within the shard, (iv) detect a shard close sentinel indicating producer-generated reconciliation attribute(s) for the shard, (v) execute the reconciliation rules for the shard to thereby generate consumer-generated reconciliation attribute(s) for the shard, (vi) reconcile the consumer-generated reconciliation attributes for the shard against the producer-generated reconciliation attributes for the shard, (vii) detect a window close sentinel indicating producer-generated reconciliation attribute(s) for the window, (viii) execute the reconciliation rules for the window to thereby generate consumer-generated reconciliation attribute(s) for the window, and (ix) reconcile the consumer-generated reconciliation attribute(s) for the window against the producer-generated reconciliation attribute(s) for the window.

Reconciliation systems and methods for unbounded streams

A computing system is configured to (i) inject, into an unbounded stream of events produced by the computing system, a window open sentinel that indicates one or more reconciliation rules for the window, (ii) inject, into the unbounded stream of events, a shard open sentinel that indicates one or more reconciliation rules for a shard, wherein the shard is within the window, (iii) transmit a set of events produced within the shard, (iv) execute the reconciliation rules for the shard to thereby generate one or more reconciliation attributes for the shard, (v) inject, into the unbounded stream of events, a shard close sentinel that indicates the reconciliation attributes for the shard, (vi) execute the reconciliation rules for the window to thereby generate one or more reconciliation attributes for the window, and (vii) inject, into the unbounded stream of events, a window close sentinel that indicates the reconciliation attributes for the window.

Growing community of inventors

London, United Kingdom

Duncan Stewart