Patent ID: 9052971
Filing Date: 2015-06-09
Classification: G06F

Abstract:
1. A method for processing events in a distributed environment comprising: providing an apparatus comprising a central queue for receiving and tracking an event, at least one filtering node, at least one correlation node and at least one update node; receiving, by the central queue, a plurality of events in their order of arrival, each event having an entry in the central queue; dividing processing of the events into three pipelined stages in the order of filtering, correlating and updating, the processing of events comprising: each event that will consume the event and update their state wherein the target objects hold all known information about the events, such that correlating the events takes place in the parallel processing environment; and wherein a result for each event of each of filtering the events, correlating the events and updating the target objects is recorded in the central queue as part of the event's queue entry, wherein the updating for each event includes one bit of information for each target object provided to the central queue to indicate that the update would affect the correlating of events subsequent to the each event and wherein the method is performed by one or more computing devices.