EXECUTING CONTINUOUS EVENT PROCESSING (CEP) QUERIES IN PARALLEL

摘要

A continuous event processing (CEP) query processor determines how and when a CEP query can be processed in a concurrent manner, such that multiple threads of execution can concurrently perform at least some of the CEP query's operations concurrently with each other. According to one technique, a user can instruct a CEP query processor to attempt to execute a CEP query in a concurrent manner. The CEP query processor responsively determines whether the CEP query's execution, or parts thereof, can be made concurrent based on certain constraints that can depend on inheritance and operation type. Based on this determination, the CEP query processor can execute at least certain parts of a CEP query in parallel relative to the same event within an event stream.

主权项

1. A computer-readable memory storing a plurality of instructions for causing a processor to perform operations, the plurality of instructions comprising:
instructions that cause the processor to split a continuous event processing (CEP) query into a plurality of separate operators; instructions that cause the processor to determine a separate constraint for each particular operator within the plurality of separate operators; instructions that cause the processor to 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 instructions that cause the processor to 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 instructions that cause the processor to 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.