Handling faults in a continuous event processing (CEP) system
First Claim
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 detect a first fault raised by the operator of a first continuous execution processing (CEP) query relative to a first event from an event stream;
instructions that cause the processor to invoke, in response to detecting the first fault, a first user-registered fault handler that has been registered with a CEP query processor;
instructions that cause the processor to determine that the first user-registered fault handler caught and handled the first fault; and
instructions that cause the processor to cause the CEP query processor, in response to determining that the first user-registered fault handler caught and handled the first fault, to continue to execute the first CEP query without halting execution of the first CEP query;
wherein the first user-registered fault handler is configured to determine whether to handle the first fault or to re-throw the first fault so that a fault handler other than the first user-registered fault handler can handle the first fault.
1 Assignment
0 Petitions
Accused Products
Abstract
The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.
-
Citations
23 Claims
-
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 detect a first fault raised by the operator of a first continuous execution processing (CEP) query relative to a first event from an event stream; instructions that cause the processor to invoke, in response to detecting the first fault, a first user-registered fault handler that has been registered with a CEP query processor; instructions that cause the processor to determine that the first user-registered fault handler caught and handled the first fault; and instructions that cause the processor to cause the CEP query processor, in response to determining that the first user-registered fault handler caught and handled the first fault, to continue to execute the first CEP query without halting execution of the first CEP query; wherein the first user-registered fault handler is configured to determine whether to handle the first fault or to re-throw the first fault so that a fault handler other than the first user-registered fault handler can handle the first fault. - View Dependent Claims (2, 3, 4, 5, 6, 7, 21, 22, 23)
-
-
8. 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; detect a first fault raised by an operator of a first continuous execution processing (CEP) query relative to a first event from an event stream; invoke, in response to detecting the first fault, a first user-registered fault handler that has been registered with a CEP query processor; determine that the first user-registered fault handler caught and handled the first fault; and cause the CEP query processor, in response to determining that the first user-registered fault handler caught and handled the first fault, to continue to execute the first CEP query without halting execution of the first CEP query; wherein the first user-registered fault handler is configured to determine whether to handle the first fault or to re-throw the first fault so that a fault handler other than the first user-registered fault handler can handle the first fault. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A method for processing a data stream of events, the method comprising:
-
detecting a first fault raised by an operator of a first continuous execution processing (CEP) query relative to a first event from an event stream; invoking, in response to detecting the first fault, a first user-registered fault handler that has been registered with a CEP query processor; determining that the first user-registered fault handler caught and handled the first fault; and causing the CEP query processor, in response to determining that the first user-registered fault handler caught and handled the first fault, to continue to execute the first CEP query without halting execution of the first CEP query; wherein the first user-registered fault handler is configured to determine whether to handle the first fault or to re-throw the first fault so that a fault handler other than the first user-registered fault handler can handle the first fault. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification