Apama Data Player

Event Data Capture and Replay

The Progress Apama platform provides sophisticated backtesting and analysis capabilities for testing of the likely behavior of Apama applications prior to deployment, as well as analysis of performance of applications that are in production. Database-persisted events drive both usages. The Apama platform supports third party event databases such as Vhayu Velocity and KX’s KDB via specific adapters, and supports third party relational databases via the Apama Database Connector (ADBC). Sources can capture and retrieve native event streams (e.g. market data feeds, RFID data streams, telemetry data, etc.), together with the “enriched events” (e.g. VWAP calculations, event threshold determinations, sensor correlations etc.) and “decision” events created within Apama Correlators through the execution of Apama applications.

Research and Analyze Event Patterns

The Apama Integration Adapter Framework integrates the Correlator and the data store. Events arriving at the data store retain time series order, taking into account the order in which the events occurred. Time series order enables Apama to replay events as they happened live, with the replay events played directly into the Correlator via the Apama Data Player. Any applications to be tested will respond in exactly the same way as they would with live events. Other features include pre-deployment testing and “digital forensics”, the analysis of existing event strategies whose execution has been recorded within the database through capture of the above-mentioned “enriched events.”

Apama Data Player

The Apama Data Player supports the replay of event data that has been captured in the event database. The Data Player is comprised of a Query Editor and Data Player Control. The Query Editor is accessible via Apama Studio and allows one to specify the data sources (the database type and specific instance) that will be sent to the Correlator for replay. This effectively activates the ADBC connection, through which events will be sourced for replay within the Correlator.