source = new AdapterInputSource(userFileName);
//registering the query with the CEP;我是EsperCEP引擎的新手。无论如何,现在我可以从csv文件中获取事件,并使用EPL语句提取数据,然后获取相关侦听器的输出值。为此,我现在使用jersey框架将应用程序开发为rest服务。
在编写服务后,我使用"postman“检查了它,但输出显示请求失败。我调试并检查了产品,直
我正在运行一个使用Esper作为核心CEP引擎的应用程序。当我尝试获取之前在Esper运行时中注册的事件类型时,我得到了一个UnsupportedOperationException。java.lang.UnsupportedOperationException: Obtaining an event type by name is only available at runtime
at com.espertech.esper.client.Configuration.getEventType(Conf
我已经编写了一些在查询中使用单行函数的ESPERCEP查询。 现在,我想使用ESPER性能工具包测量查询的延迟和吞吐量。= select '$' as ticker, compute_average(e) from Market(ticker='$')#time(5 seconds) as e 如何使用性能工具包测量ESPER
我有一个使用Esper运行CEP的多线程程序。虽然已经通过引擎发送了事件,但我创建了一个新语句并设置了一个订阅者。因为createEPL方法自动启动语句,所以在语句启动和设置订阅者之间,我可能会错过由语句触发的update。updates but it potentially missed some since the statement was created 我可以创建自己的锁来处理这个问题,但我想知道,它们是否是同时创建语句和设置由EsperAPI提供的订阅者的替代方法?