US6681230B1
Expired / Lapsed
US
⏱️ 0.0 years remaining
Real-time event processing system with service authoring environment
Assignee: RPX Corp
•
Filing: 1999-03-25
•
Granted: 2004-01-20
•
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
- 👤 Stephen M. Blott
- 👤 Yuri Breitbart
- 👤 Thomas M. Cliff, Jr.
- 👤 Frank Frastaci, Jr.
- 👤 Henry F. Korth
Bibliographic Details
Application Number
—
Jurisdiction
US
Data Source
google_patents
Last Synchronized
2026-11-03 21:30
CPC Classifications
G; G06; G06F; G06F8/00; G06F8/30; G06F8/38; Y; Y10; Y10S; Y10S707/00; Y10S707/99941; Y10S707/99944; Y10S707/99945; Y10S707/99948
Claims Analysis
Total Claims: 31
Claim 1
Independent Claim
173 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
Claim 2
Independent Claim
173 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
Claim 3
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 4
Dependent Claim
38 words
The apparatus of claim 2 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 5
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 6
Dependent Claim
21 words
The apparatus of claim 1 wherein the processor executes code to implement at least a portion of a main-memory database system.
Claim 7
Dependent Claim
31 words
The apparatus of claim 5 wherein the real-time analysis engine processes the events utilizing data stored in a memory portion of the main-memory database system accessible to the real-time analysis engine.
Claim 8
Dependent Claim
43 words
The apparatus of claim 1 wherein both base tables and views are stored explicitly in a memory portion of a main-memory database system accessible to the real-time analysis engine, but chronicles are not stored in the memory portion of the main-memory database system.
Claim 9
Dependent Claim
34 words
The apparatus of claim 1 wherein at least one of the services generated in the service authoring environment and implemented in the real-time analysis engine is an application-specific service associated with the system application.
Claim 10
Independent Claim
123 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes at least one graphical user interface for generating at least one of the services, a static check element for processing a service generated by the graphical user interface, and a translation and compilation element for generating program code for implementing the service within the real-time analysis engine.
Claim 11
Independent Claim
123 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes at least one graphical user interface for generating at least one of the services, a static check element for processing a service generated by the graphical user interface, and a translation and compilation element for generating program code for implementing the service within the real-time analysis engine.
Claim 12
Independent Claim
101 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment generates at least one of the services in the form of object code which is dynamically linked into the real-time analysis engine without interrupting event processing.
Claim 13
Independent Claim
101 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment generates at least one of the services in the form of object code which is dynamically linked into the real-time analysis engine without interrupting event processing.
Claim 14
Independent Claim
136 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein at least one service generated by the service authoring environment includes: a set of event handlers for implementing an application-specific service; configuration, summary and aggregation data used to support event processing; a set of queries that can be invoked within the system application; and a set of input and output streams which interface the real-time analysis engine to a data source and data sink, respectively.
Claim 15
Independent Claim
136 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein at least one service generated by the service authoring environment includes: a set of event handlers for implementing an application-specific service; configuration, summary and aggregation data used to support event processing; a set of queries that can be invoked within the system application; and a set of input and output streams which interface the real-time analysis engine to a data source and data sink, respectively.
Claim 16
Independent Claim
128 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes a translation and compilation element that converts code in a service authoring language into a component comprising at least one dynamically linked library which is linked into a running process associated with the real-time analysis engine to implement at least a portion of an application-specific service implemented in the real-time analysis engine.
Claim 17
Independent Claim
128 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 in accordance with at least one service implemented therein, wherein the service is generated by compiling code generated in a service authoring environment associated with the real-time analysis engine; wherein the service authoring environment includes a translation and compilation element that converts code in a service authoring language into a component comprising at least one dynamically linked library which is linked into a running process associated with the real-time analysis engine to implement at least a portion of an application-specific service implemented in the real-time analysis engine.
Claim 18
Independent Claim
162 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
Claim 19
Independent Claim
162 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
Claim 20
Dependent Claim
52 words
The method of claim 13 further including the steps of receiving the events in the real-time analysis engine in the form of one or more input streams from at least one data source; and delivering information representative of processed events in one or more output streams to at least one data sink.
Claim 21
Dependent Claim
32 words
The method of claim 13 wherein the processing step further includes processing the events utilizing data stored in a memory portion of a main-memory database system accessible to the real-time analysis engine.
Claim 22
Dependent Claim
43 words
The method of claim 13 wherein both base tables and views are stored explicitly in a memory portion of a main-memory database system accessible to the real-time analysis engine, but chronicles are not stored in the memory portion of the main-memory database system.
Claim 23
Dependent Claim
34 words
The method of claim 13 wherein at least one of the services generated in the service authoring environment and implemented in the real-time analysis engine is an application-specific service associated with the system application.
Claim 24
Independent Claim
112 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes at least one graphical user interface for generating at least one of the services, a static check element for processing a service generated by the graphical user interface, and a translation and compilation element for generating program code for implementing the service within the real-time analysis engine.
Claim 25
Independent Claim
112 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes at least one graphical user interface for generating at least one of the services, a static check element for processing a service generated by the graphical user interface, and a translation and compilation element for generating program code for implementing the service within the real-time analysis engine.
Claim 26
Independent Claim
90 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the generating step includes generating at least one of the services in the form of object code which is dynamically linked into the real-time analysis engine without interrupting event processing.
Claim 27
Independent Claim
90 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the generating step includes generating at least one of the services in the form of object code which is dynamically linked into the real-time analysis engine without interrupting event processing.
Claim 28
Independent Claim
117 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a translation and compilation element that converts code in a service authoring language into a component comprising at least one dynamically linked library which is linked into a running process associated with the real-time analysis engine to implement at least a portion of an application-specific service implemented in the real-time analysis engine.
Claim 29
Independent Claim
117 words
A method of processing events generated by at least one system application, the method comprising the steps of: generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine; and processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a translation and compilation element that converts code in a service authoring language into a component comprising at least one dynamically linked library which is linked into a running process associated with the real-time analysis engine to implement at least a portion of an application-specific service implemented in the real-time analysis engine.
Claim 30
Dependent Claim
182 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) generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine, and (ii) processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
Claim 31
Dependent Claim
182 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) generating code in a service authoring environment associated with at least one real-time analysis engine to provide a service which is implemented in the real-time analysis engine, and (ii) processing the events in the real-time analysis engine in accordance with the service; wherein the service authoring environment includes a declarative language for use in generating the services, wherein the language includes a set of procedural programming constructs and a set of declarative data-management constructs; and wherein the declarative language includes one or more of the following data structures: (i) a base table which supports insert, update, delete and select operators, (ii) a chronicle which supports insert and select operators, wherein an insert into a chronicle corresponds to generation of a record on an output stream, and (iii) a view which supports a select operator and whose contents are derived from one or more other tables.
References Cited (Backward Citations)
USPTO Annuity & Maintenance Windows
| Annuity Stage | Window Opens | Payment Deadline | Surcharge Period Until | Estimated Fee | Status |
|---|---|---|---|---|---|
| 3.5 Years (Year 4) | 2007-01-19 | 2007-07-21 | 2008-01-20 | $2000.00 | Window Closed / Lapsed |
| 7.5 Years (Year 8) | 2011-01-19 | 2011-07-21 | 2012-01-20 | $3760.00 | Window Closed / Lapsed |
| 11.5 Years (Year 12) | 2015-01-19 | 2015-07-21 | 2016-01-20 | $7700.00 | Window Closed / Lapsed |