CEP API Reference
The Complex Event Processing (CEP) engine is used to extract information, identify patterns, and perform real-time analysis and decision-making from large-scale streaming data.
| Category | Functions | Description |
|---|---|---|
| Engine | createCEPEngine | Creates a CEP engine. |
| stopSubEngine | Stops a sub engine. | |
| dropStreamEngine | Releases a specific CEP engine. | |
| Event | appendEvent | Appends events to the CEP engine. |
| appendEventWithResponse |
Appends events to the CEP engine and blocks the current thread until a matching response event is received or the wait times out. |
|
| sendEvent | Sends an event to the end of the input queue of the current sub engine. | |
| routeEvent | Sends an event to the front of the input queue of the current sub engine. | |
| emitEvent | Sends an event to the end of the CEP engine's output queue asynchronously. | |
| Monitor | spawnMonitor | Creates a monitor instance. |
| getCEPEngineMonitor |
Gets a specified or all initial (non-spawned) monitor instances from the specified CEP engine for inspecting their member variables. |
|
| getCEPEngineSubMonitor | Gets the sub-monitors spawned by the specified monitor within a CEP engine. | |
| destroyMonitor | Terminates monitor instances. | |
| Listenser | addEventListener | Specifies an event matching rule and a callback function, and returns an event listener instance. |
| getEventListener | Queries the event listener instances registered in the current monitor. | |
| terminate | Stops the current event listener. | |
| Stream Event Serializer | streamEventSerializer | Serializes events into BLOB and writes them to a heterogeneous stream table. |
| Status Monitoring | getStreamEngineStat().CEPEngine | Checks the status of all current CEP engines. |
| getCEPEngineStat | Checks the status of a specific CEP engine. | |
| Data View | createDataViewEngine | Creates a data view engine. |
| getDataViewEngine | Gets the handle of data view engine defined in a specific CEP engine. | |
| getStreamEngine | Retrieves data from the specified data view engine created outside the CEP engine. | |
| updateDataViewItems | Updates the data with the specified keys from a data view engine. | |
| deleteDataViewItems | Deletes the data with the specified keys from a data view engine. | |
| dropDataViewEngine | Deletes the specified data view engine in the current CEP engine. |