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.

Ein Verarbeitungssystem des Realzeitfalls (EPS) für die Verarbeitung einer Ereignisreihenfolge erzeugt durch eine oder mehr Anwendungen. In einer illustrativen Verkörperung schließt das EPS einen Satz Realzeitanalyse Maschinen (RAEs) funktionierend in der Ähnlichkeit z.B. ein Satz Blöcke jeder einschließlich ein oder mehr RAEs und einen oder mehr Kartographen für das Diagramm eines gegebenen Eingang Falls bis ein bestimmtes der Blöcke ein. Ein Zentralspeicherdatenbanksystem wird zum RAEs und zu den RAEs Prozeßschritten, die mit Eingang Strömen von einer oder mehr Datenquellen verbunden sind verbunden und Ausgang Ströme an eine oder mehr Datensenken liefert. Die Datenquelle- und Datensenken können z.B. Netzelemente, Klienten, Datenbanken, usw. sein. Die Fälle werden in Übereinstimmung mit den Dienstleistungen verarbeitet, die im RAEs eingeführt werden und die Daten verwenden, die in einem Gedächtnisteil des Zentralspeicherdatenbanksystems gespeichert werden, das zum RAEs zugänglich ist. Die Daten können z.B. eine Subskription Tabelle mit einschließen, welche die Subskription Informationen speichert, die den Service oder die Dienstleistungen, die, anzeigen für einen gegebenen Fall durchgeführt werden sollten. Die Dienstleistungen werden in einem Service erzeugt, der Klima (SAE) schreibt im EPS mit einer feststellenden Sprache. Das SAE erzeugt die Dienstleistungen in Form von Objektcodebestandteilen z.B. dynamisch Hauptbibliotheken, die in das RAEs ohne unterbrechendes Fallzu verarbeiten dynamisch verbunden werden können. Die Wiederaufnahme Informationen betreffend sind einen Wiederaufnahme Punkt für ein gegebenes RAE oder Satz von RAEs im EPS können in einem Gedächtnisteil des Zentralspeicherdatenbanksystems gespeichert werden, und verwendet werden, um ein Zurückrollen des RAE zum Wiederaufnahme Punkt einzuführen.