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 引擎。 |