CEP 相关函数
复杂事件处理引擎用于从大规模实时数据流中提取信息、识别模式并进行实时分析和决策。本文提供 CEP
引擎相关函数的概览,包括核心函数、事件注册、流表操作及策略管理,方便快速查阅和使用。
| 分类 | 函数名 | 函数简介 |
|---|---|---|
| 引擎 | createCEPEngine | 创建 CEP 引擎。 |
| stopSubEngine | 停止子引擎。 | |
| dropStreamEngine | 释放指定的 CEP 引擎。 | |
| 事件 | appendEvent | 向 CEP 引擎写入事件。 |
| sendEvent | 将事件插入到当前子引擎的事件处理队列的尾部。 | |
| routeEvent | 将事件插入到当前子引擎的事件处理队列的队首。 | |
| emitEvent | 将事件插入到 CEP 引擎的事件输出队列的队尾。引擎会异步地将事件发送到输出队列。 | |
| monitor | spawnMonitor | 创建一个 monitor 实例。 |
| getCEPEngineMonitor | 获取指定 CEP 引擎中指定或所有一级(非 spawn)monitor 实例。 | |
| getCEPEngineSubMonitor | 获取指定 monitor 在指定 CEP 引擎中生成的 subMonitor。 | |
| destroyMonitor | 终止 monitor 实例。 | |
| listenser | addEventListener | 指定事件匹配规则和回调函数,返回一个 EventListener 实例。 |
| getEventListener | 查询当前 monitor 中已注册的事件监听器实例。 | |
| terminate | 终止该 EventListener 实例,不再触发回调。 | |
| 事件流序列化 | streamEventSerializer | 将事件序列化为 BLOB 格式,写入到异构流表。 |
| 监控运维 | getStreamEngineStat().CEPEngine | 查看当前所有 CEP 引擎的状态。 |
| getCEPEngineStat | 查看指定 CEP 引擎当前的运行状态,包括 CEP 引擎及其子引擎的状态。 | |
| 数据视图 | createDataViewEngine | 创建一个 DataView 引擎。 |
| getDataViewEngine | 获取在 CEP 引擎内部创建的指定 DataView 引擎的数据。 | |
| getStreamEngine | 获取在 CEP 引擎外部创建的指定 DataView 引擎的数据。 | |
| updateDataViewItems | 更新 DataView 引擎中指定键值对应的指定字段的值。 | |
| deleteDataViewItems | 删除 DataView 引擎中指定键值的数据。 | |
| dropDataViewEngine | 删除当前 CEP 引擎中指定的 DataView 引擎。 |
