用于历史/实时/重播的数据的复杂事件处理器

摘要

描述了一种复杂事件处理器，其具有通信接口，其被配置为通过从一个或多个源拉取事件数据来检索事件数据并且接收被推送到该接口的至少一个实时事件流。连接到通信接口的事件处理管道包括连接在通信接口和组合器节点之间的多个运算符节点，组合器节点是被配置为组合来自源和来自实时事件流的事件数据的节点。通信接口被配置为从源检索事件并将从源检索的事件沿事件处理管道推送到组合器节点。通信接口被配置为仅响应于沿着管道在从组合器节点到通信接口的上游方向上传递的请求消息来检索和推送检索到的事件。