Esper是EsperTech Inc.开发的CEP(复杂事件处理)和ESP(事件流处理)应用程序的轻量级开源库。
Esper 或 Siddhi 用于聚合事件处理和可扩展到大量任务
我有以下任务:假设我正在开发一个由一百万用户使用的在线商店。用户在不同的时间进行购买。每个用户的每次购买都会变成一次交易事件。我...
Java java.io.ObjectInputStream.readObject 的本机构建问题
我正在尝试使用名为 EsperTech 的依赖项以本机模式构建我的 quarkus 应用程序,并且有一段特定的代码片段,经过无数个小时的调试后,我发现这导致...
我有一个关于 Java 中的 Esper 的问题。想象一下,我有一个事件,每个事件有两个元素:金钱、名称。 我想做的是输出3个钱最多的不同名字。是...
我正在从事一个项目,其中有连续的事件流。有许多并发用户可以创建/更新/删除规则,并在流与这些规则匹配时收到警报。 我用过
尽管模式匹配,Esper Listener 中的 getUnderlying() 为空
我正在使用 Esper 8.9 在 Spring Boot 应用程序中进行复杂的事件处理。尽管正确配置了我的事件和模式,我的 UpdateListener 实现中的 getUnderlying() 方法仍然...
我有这种模式,我想将其应用于事件流以检测两个不按顺序发生的事件,并且它们具有一个相等的属性。然而,该语句返回正常,但是
我正在与 Esper 合作,但我不清楚一些事情。谁能帮我解释一下吗? 事件何时会从流中删除? 事件什么时候会从窗口中删除? 难道是……
使用 Esper 如何从第一个事件时间戳开始 X 分钟的窗口?
我正在尝试启动一个窗口并使其存活 X 分钟。 选择a,b 来自 Event.win:time(120) -> 这给了我一个滑动窗口 匹配识别( 按传感器分区 ... ) 我也试过了 小...
我读到的所有资料都说这应该能用 我需要我的监听器每10秒触发一次事件。我现在得到的是每一个事件,它是一个监听器触发。我错过了什么?基本的...
在Esper 8.5中如何在部署语句时设置StatementIdStatement名称。
在Esper版本5中,我们使用下面的代码注册EPL语句并添加监听器 - final EPStatement statement = admin.createEPL(epl, subsc.getId().toString(), subsc); statement.......
current_timestamp()在WHERE子句缓存结果。这是预期的行为吗?
在Esper線上(8.5 - https:/esper-epl-tryout.appspot.comepltryoutmainform.html),似乎current_timestamp()單行方法在WHERE部分出現時是作為一個快取的方法。...
addPlugInSingleRowFunction中的问题将Esper版本从5.3升级到8.3
在我们现有的应用程序中,我们使用的是Esper版本5.3。我们添加了一些addPlugInSingleRowFunction()以便在EPL中使用它,如下所示-最终配置cepConfiguration = new Configuration(); ...
我正在尝试使用Esper Dataflows做一些测试,所以我正在使用Esper Dataflows提供的Select运算符编写一些模式。但是我没有让它工作。我正在尝试使用的代码...
关于具有esper CEP的match_recognize语法的问题
使用esper进行CEP查询时,我使用match_recognize语法。我注意到,在匹配某些事件之后,它将在以后的比赛中忽略它们。例如,如果使用下面的简单...
要求:1.当A事件和B事件在5秒内到达时,输出C事件2.当A事件或B事件到达时,输出C事件我可以这样写epl:“从A.std中插入C select * :lastevent()...
是否有可能在具有ARM Cortex M4 120 MHz核心的微控制器LPC4088中运行Esper CEP?我想知道是否可以在JVM或Nesper for .NET中使用它。谢谢]]
为了在运行时部署Esper工作流,必须在Esper 8中使用RMI服务器
我正在尝试制作一个Esper应用程序,该应用程序允许我运行时部署基于数据流的模式。为了实现这一点,我使用了基于RMI的服务器来发送模式,但是考虑到这一点,它...