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.
В реальном масштабе времени системы обработки случая (EPS) для обрабатывать последовательность случаев произведенных one or more применениями. В иллюстративное воплощение, EPS вклюает комплект в реальном масштабе времени двигателей анализа (RAEs) работая параллельно, например, комплект групп каждое включая one or more RAEs, и one or more mappers для составлять карту, котор дали случай входного сигнала до определенное одна из групп. Main-memory система базы данных соединена к RAEs, и процессам обработки RAEs связанным с входными потками от one or more источников данных и поставляет потоки выхода к one or more раковинам данных. Раковины источника данных и данных могут быть, например, элементами сети, клиентами, базами данных, etc. Случаи обработаны в соответствии с обслуживаниями снабженными в RAEs, и используют данные, котор хранят в части памяти main-memory системы базы данных доступной к RAEs. Данные могут включить, например, таблицу подписки данные по подписки показывая обслуживание или обслуживания которое должны быть исполнены для, котор дали случая. Обслуживания произведены в обслуживании authoring окружающая среда (sae) в EPS, использующ декларативный язык. Sae производит обслуживания in the form of компоненты обжектного кода, например, dynamically связ с архивом, которые могут dynamically быть соединены в RAEs без прерывая обрабатывать случая. Данные по спасения относительно пункта спасения для, котор дали RAE или комплекта RAEs в EPS могут храниться в части памяти main-memory системы базы данных, и использоваться для того чтобы снабдить roll-back RAE к пункту спасения.
