| CPC G06F 11/3409 (2013.01) [G06F 9/542 (2013.01); G06F 11/0772 (2013.01)] | 14 Claims |

|
1. A system to monitor data consistency in a data pipeline, the system comprising:
processing circuitry configured to:
monitor operations of the data pipeline;
utilize a Sigmoid function to calculate weighted sums of data values, data records, and data schemas in the pipeline outputs;
generate a consistency score that indicates a similarity level between pipeline outputs based on the weighted sums;
determine when the consistency score exceeds a threshold; and
when the consistency score exceeds the threshold, transfer an alert that indicates ones of the pipeline outputs that exceeded the threshold value.
|