The present systems and methods allow for rapid processing of large volumes of events. A
producer node in a cluster determines a sharding key for a received event from an event …

Abstract Systems and methods are provided to process an event stream using nodes
arranged as a cluster in which the nodes are in a leader-follower relationship with one node …

Scalable systems and methods for near real time processing of a substantial volume of
event data streams are disclosed. A concurrent throughput receiver is coupled to an input of …

In one embodiment, a system for distributed event processing includes a first event
processor and a second event processor. The first event processor receives event data …

Methods, systems, and computer-readable media for globally ordered event stream logging
are disclosed. A first host of a plurality of hosts generates an additional chain of a stream …

An event processing system for processing events in an event stream is disclosed. The
system is configured for determining a stage for a continuous query language (CQL) query …

An event processing system is disclosed that processes events of an event stream and
performs the recovery of events during system failure. The recovery of events is performed …

An event server receiving input streams of events and producing output streams of events is
adapted to be clustered with other event servers. The event server uses configuration data to …

Certain example embodiments described herein relate to forecasting the future behavior of
event streams in Complex Event Processing (CEP) environments. For each received event …

Techniques for facilitating and accelerating log data pro cessing by splitting data streams
are disclosed herein. The front-end clusters generate large amount of log data in real time …