Complex event processor for historic/live/replayed data

摘要

A complex event processor is described which has a communications interface configured to retrieve event data by pulling it from one or more sources and to receive at least one live event stream pushed to the interface. An event processing pipeline connected to the communications interface comprises a plurality of operator nodes connected between the communications interface and a combiner node which is a node configured to combine event data from the source and from the live event stream. The communications interface is configured to retrieve events from the source and to push the events retrieved from the source along the event processing pipeline towards the combiner node. The communications interface is configured to retrieve and push the retrieved events only in response to request messages passed in an upstream direction from the combiner node to the communications interface along the pipeline.

主权项

1. A system comprising:
at least one processor adapted to execute computer executable instructions associated with nodes of an event processing pipeline; a communications interface communicatively coupled to the at least one processor and configured to:
pull first event data from at least one source in response to a request message; andreceive second event data pushed to the communications interface, the second event data associated with at least one live/replayed event stream; and at least one computer-readable medium communicatively coupled to the at least one processor and nodes of the event processing pipeline stored on the computer-readable medium and executable by the processor, the nodes comprising:
a first group of operator node(s) connected between the communications interface and a combiner node, the first group of operator node(s) configured to provide third event data based at least in part on the first event data;a second group of operator node(s) connected between the communications interface and the combiner node, the second group of operator node(s) configured to provide fourth event data based at least in part on the second event data; andthe combiner node configured to:
determine a request time based at least in part on at least some of the fourth event data;provide the request message comprising the request time to the communications interface via the first group of operator node(s); andcombine at least some of the third event data and at least some of the fourth event data.