CPC G06F 9/542 (2013.01) [G06F 16/24575 (2019.01); G06N 7/01 (2023.01)] | 22 Claims |
1. A computer-implemented method for processing a data stream comprising events, the method comprising:
receiving, by a server, a data stream comprising a plurality of events at a plurality of processing nodes;
at a first processing node,
processing, by the server, on a first event and a known instance of a second event to determine whether the first event matches the known instance of the second event;
in response to determining that the first event does not match the known instance of the second event, terminating, by the server, the processing without generating an output, and generating, by the server, a probabilistic event having a resulting probability computed based on a confidence value of the first event and a first probabilistic value of a first missing event, or
in response to determining that the first event matches the known instance of the second event, generating, by the server, a first output event having a resulting probability computed based on the confidence value of the first event; and
at a second processing node,
receiving, by the server, the first output event or the probabilistic event as a first input event;
matching, by the server, the first input event against a first pattern;
if the first input event matches the first pattern, generating, by the server, a new event having a confidence value computed based on a confidence value of the first input event, or
if the first input event does not match or partially matches the first pattern, generating, by the server, a first placeholder event having a confidence value computed based on the confidence value of the first input event and a second probabilistic value of a second missing event.
|