java - CEP 引擎 (Esper) 中的多个流

Question

我是 esper 引擎的新手，我不确定多个流的含义。我想创建这样的东西：

 CepEnigine cep = new CepEngine();
 Controller.getInstance().setRuntime(cep.getRuntime());

 for(int i = 0; i < 5; i++)
     new EventGenerator().start();

事件生成器类定义如下：

public class EventGenerator extends Thread
{
    @Override
    public void run()
    {
        while (true)
        {
             MyEvent e = new Event();
             Controller.getInstance().sendToCEP(e);
             Thread.sleep(500);
        }
    }
}

控制器是保持 epruntime 发送事件的多线程单例。在 CepEngine 类中，我还有用于监听事件的 EPL 语句。这是多个事件流的好含义吗？

谢谢

Answer 1

事件流是“按时间顺序排列的事件序列”

Esper 常见问题供参考

在您给出的示例中，有一个名为 MyEvent 的 eventStream

多流示例是 Order 和 OrderBook 的流。我们可以从 Order 事件中过滤出 Order for book 并创建一个 orderBook 事件流，

在 esper 代码库TestFilterPropertySimple中检查此测试