Event Processor

The core of the Aleri Streaming Platform is the high speed event processor, a server process that receives incoming data and applies the logic defined using the authoring tools (described below) - in real-time - to produce derived data streams. These derived streams can be used in several ways:

• Continuous streaming output

  Applications can subscribe to one or more derived streams. Every delta is published in real-time as it happens.

• Event Triggers

  Application level functions written in C, C++, or Java can be registered with the Aleri Streaming Platform in conjunction with a derived stream and will be invoked whenever that stream updates.

• On-Demand Queries

  Derived steams can be configured to retain a "window" of data that can be queried as needed via standard SQL queries via the ODBC or JDBC interface. This allows off-the-shelf query/reporting tools to access data on demand.

• Historic Data Collection

  Raw and derived event data can be collected and periodically migrated to an off-the-shelf database to maintain an historical repository; optional disk-based data persistence can be used to ensure that data cannot be lost in between the periodic migrations.