US6502133B1
Expired / Lapsed
US
⏱️ 0.0 years remaining
Real-time event processing system with analysis engine using recovery information
Assignee: Alcatel Lucent SAS
•
Filing: 1999-03-25
•
Granted: 2002-12-31
•
Expires: 2019-03-25
Abstract
Abstract A real-time event processing system (EPS) for processing a sequence of events generated by one or more applications. In an illustrative embodiment, the EPS includes a set of real-time analysis engines (RAEs) operating in parallel, e.g., a set of clusters each including one or more RAEs, and one or more mappers for mapping a given input event to a particular one of the clusters. A main-memory database system is coupled to the RAEs, and the RAEs process events associated with input streams from one or more data sources and deliver output streams to one or more data sinks. The data source and data sinks may be, e.g., network elements, clients, databases, etc. The events are processed in accordance with services implemented in the RAEs, and utilize data stored in a memory portion of the main-memory database system accessible to the RAEs. The data may include, e.g., a subscription table storing subscription information indicating the service or services that should be executed for a given event. The services are generated in a service authoring environment (SAE) in the EPS, using a declarative language. The SAE generates the services in the form of object code components, e.g., dynamically linked libraries, which may be dynamically linked into the RAEs without interrupting event processing. Recovery information regarding a recovery point for a given RAE or set of RAEs in the EPS may be stored in a memory portion of the main-memory database system, and utilized to implement a roll-back of the RAE to the recovery point.
Inventors
- 👤 Gerald D. Baulier
- 👤 Stephen M. Blott
- 👤 Philip L. Bohannon
- 👤 Benson L. Branch
- 👤 Thomas M. Cliff, Jr.
Bibliographic Details
Application Number
—
Jurisdiction
US
Data Source
google_patents
Last Synchronized
2026-11-03 22:06
CPC Classifications
G; G06; G06F; G06F9/00; G06F9/06; G06F9/46; G06F9/54; G06F9/542; G06F11/00; G06F11/07; G06F11/14; G06F11/1474; G06F9/544; G06F9/547; G06F11/1471; G06F11/30; G06F11/34; G06F11/3466; G06F11/3476; G06F2201/00; G06F2201/86
Claims Analysis
Total Claims: 24
Claim 1
Independent Claim
66 words
An apparatus for processing events generated by at least one system application, the apparatus comprising: a processor for executing code to implement at least a portion of at least one real-time analysis engine, wherein the real-time analysis engine processes the events, and wherein associated with the real-time analysis engine in a main-memory database system is recovery information regarding a recovery point for the real-time analysis engine.
Claim 2
Independent Claim
66 words
An apparatus for processing events generated by at least one system application, the apparatus comprising: a processor for executing code to implement at least a portion of at least one real-time analysis engine, wherein the real-time analysis engine processes the events, and wherein associated with the real-time analysis engine in a main-memory database system is recovery information regarding a recovery point for the real-time analysis engine.
Claim 3
Dependent Claim
24 words
The apparatus of claim 1 wherein serial tags are assigned to each of the events in accordance with an arrival order of the events.
Claim 4
Dependent Claim
25 words
The apparatus of claim 2 wherein the serial tags are assigned in a monotonically increasing sequence in accordance with the arrival order of the events.
Claim 5
Dependent Claim
18 words
The apparatus of claim 3 wherein the tags and the corresponding events are stored in an event log.
Claim 6
Dependent Claim
29 words
The apparatus of claim 2 wherein the recovery information includes the serial tag for each event for which processing in the real-time analysis engine has reached a commit operation.
Claim 7
Dependent Claim
42 words
The apparatus of claim 5 wherein the serial tags for each event for which processing in the real-time analysis engine has reached a commit operation are stored in a memory portion of the main-memory database system accessible to the real-time analysis engine.
Claim 8
Dependent Claim
42 words
The apparatus of claim 6 wherein after an event is processed and the results of the processing stored in an external database storage element, the serial tag of the event is stored in a serial tag log associated with that storage element.
Claim 9
Dependent Claim
44 words
The apparatus of claim 7 wherein the serial tags stored in the memory portion of the main-memory database system and the serial tags stored in the serial tag log are utilized to implement a roll-back of the real-time analysis engine to the recovery point.
Claim 10
Dependent Claim
47 words
The apparatus of claim 1 wherein the real-time analysis engine receives the events in the form of one or more input streams from at least one data source, and delivers information representative of processed events in one or more output streams to at least one data sink.
Claim 11
Dependent Claim
38 words
The apparatus of claim 9 wherein at least one of the data source and the data sink comprises at least one of a network element of the system, a client associated with the application, and a database element.
Claim 12
Dependent Claim
23 words
The apparatus of claim 1 further including a plurality of processors for executing code to implement the at least one real-time analysis engine.
Claim 13
Dependent Claim
21 words
The apparatus of claim 1 wherein the processor executes code to implement at least a portion of the main-memory database system.
Claim 14
Independent Claim
52 words
A method of processing events generated by at least one system application, the method comprising the steps of: processing the events in at least one real-time analysis engine; and storing in a main-memory database system associated with the real-time analysis engine recovery information regarding a recovery point for the real-time analysis engine.
Claim 15
Independent Claim
52 words
A method of processing events generated by at least one system application, the method comprising the steps of: processing the events in at least one real-time analysis engine; and storing in a main-memory database system associated with the real-time analysis engine recovery information regarding a recovery point for the real-time analysis engine.
Claim 16
Dependent Claim
27 words
The method of claim 13 further including the step of assigning serial tags to each of the events in accordance with an arrival order of the events.
Claim 17
Dependent Claim
29 words
The method of claim 14 wherein the recovery information includes the serial tag for each event for which processing in the real-time analysis engine has reached a commit operation.
Claim 18
Dependent Claim
45 words
The method of claim 15 further including the step of storing the serial tags for each event for which processing in the real-time analysis engine has reached a commit operation in a memory portion of the main-memory database system accessible to the real-time analysis engine.
Claim 19
Dependent Claim
45 words
The method of claim 16 further including the step of, after an event is processed and the results of the processing stored in an external database storage element, storing the serial tag of the event in a serial tag log associated with that storage element.
Claim 20
Dependent Claim
47 words
The method of claim 17 further including the step of utilizing the serial tags stored in the memory portion of the main-memory database system and the serial tags stored in the serial tag log to implement a roll-back of the real-time analysis engine to a recovery point.
Claim 21
Dependent Claim
28 words
The method of claim 14 wherein the assigning step includes assigning the serial tags in a monotonically increasing sequence in accordance with the arrival order of the events.
Claim 22
Dependent Claim
18 words
The method of claim 14 further including storing the tags and the corresponding events in an event log.
Claim 23
Dependent Claim
72 words
An article of manufacture comprising a machine-readable medium for storing one or more programs for processing events generated by at least one system application, wherein the programs when executed by a processor implement the steps of: (i) processing the events in at least one real-time analysis engine; and (ii) storing in a main-memory database system associated with the real-time analysis engine recovery information regarding a recovery point for the real-time analysis engine.
Claim 24
Dependent Claim
72 words
An article of manufacture comprising a machine-readable medium for storing one or more programs for processing events generated by at least one system application, wherein the programs when executed by a processor implement the steps of: (i) processing the events in at least one real-time analysis engine; and (ii) storing in a main-memory database system associated with the real-time analysis engine recovery information regarding a recovery point for the real-time analysis engine.
References Cited (Backward Citations)
US5828845A
Cited
US5751798A
Cited
USPTO Annuity & Maintenance Windows
| Annuity Stage | Window Opens | Payment Deadline | Surcharge Period Until | Estimated Fee | Status |
|---|---|---|---|---|---|
| 3.5 Years (Year 4) | 2005-12-30 | 2006-07-01 | 2006-12-31 | $2000.00 | Window Closed / Lapsed |
| 7.5 Years (Year 8) | 2009-12-30 | 2010-07-01 | 2010-12-31 | $3760.00 | Window Closed / Lapsed |
| 11.5 Years (Year 12) | 2013-12-30 | 2014-07-01 | 2014-12-31 | $7700.00 | Window Closed / Lapsed |