Executing continuous event processing (cep) queries in parallel

A system for processing a data stream of events, the system comprising:

• a memory storing a plurality of instructions:
• and
• a processor coupled to the memory, the processor configured to execute the plurality of instructions to:
• split a continuous event processing (CEP) query into a plurality of separate operators;
• determine a separate constraint for each particular operator within the plurality of separate operators;
• determine a constraint for the CEP query based at least in part on the constraints that the processor determined for the plurality of separate operators;
• and
• determine, based on the constraint for the CEP query, whether at least a part of the CEP query can be executed in a concurrent manner;
• and
• spawn multiple threads of execution that concurrently process events from an event stream in response to determining that at least part of the CEP query can be executed in a concurrent manner.

A method for processing a data stream of events, the method comprising:

• splitting a continuous event processing (CEP) query into a plurality of separate operators;
• determining a separate constraint for each particular operator within the plurality of separate operators;
• determining a constraint for the CEP query based at least in part on the constraints that the processor determined for the plurality of separate operators;
• and
• determining, based on the constraint for the CEP query, whether at least a part of the CEP query can be executed in a concurrent manner;
• and
• spawning multiple threads of execution that concurrently process events from an event stream in response to determining that at least part of the CEP query can be executed in a concurrent manner.