esper 相关问题

Esper是EsperTech Inc.开发的CEP(复杂事件处理)和ESP(事件流处理)应用程序的轻量级开源库。

尽管模式匹配,Esper Listener 中的 getUnderlying() 为空

我正在使用 Esper 8.9 在 Spring Boot 应用程序中进行复杂的事件处理。尽管正确配置了我的事件和模式,我的 UpdateListener 实现中的 getUnderlying() 方法仍然...

回答 1 投票 0

检索 esper epl 模式中的所有事件

我有这种模式,我想将其应用于事件流以检测两个不按顺序发生的事件,并且它们具有一个相等的属性。然而,该语句返回正常,但是

回答 1 投票 0

Esper 对象表示和处理的一般信息

我正在与 Esper 合作,但我不清楚一些事情。谁能帮我解释一下吗? 事件何时会从流中删除? 事件什么时候会从窗口中删除? 难道是……

回答 1 投票 0

使用 Esper 如何从第一个事件时间戳开始 X 分钟的窗口?

我正在尝试启动一个窗口并使其存活 X 分钟。 选择a,b 来自 Event.win:time(120) -> 这给了我一个滑动窗口 匹配识别( 按传感器分区 ... ) 我也试过了 小...

回答 2 投票 0

Esper EPL 窗口选择不能用于基本的例子。

我读到的所有资料都说这应该能用 我需要我的监听器每10秒触发一次事件。我现在得到的是每一个事件,它是一个监听器触发。我错过了什么?基本的...

回答 1 投票 0

在Esper 8.5中如何在部署语句时设置StatementIdStatement名称。

在Esper版本5中,我们使用下面的代码注册EPL语句并添加监听器 - final EPStatement statement = admin.createEPL(epl, subsc.getId().toString(), subsc); statement.......

回答 1 投票 0

current_timestamp()在WHERE子句缓存结果。这是预期的行为吗?

在Esper線上(8.5 - https:/esper-epl-tryout.appspot.comepltryoutmainform.html),似乎current_timestamp()單行方法在WHERE部分出現時是作為一個快取的方法。...

回答 1 投票 1

addPlugInSingleRowFunction中的问题将Esper版本从5.3升级到8.3

在我们现有的应用程序中,我们使用的是Esper版本5.3。我们添加了一些addPlugInSingleRowFunction()以便在EPL中使用它,如下所示-最终配置cepConfiguration = new Configuration(); ...

回答 1 投票 0

Esper数据流中“ Where子句”中的错误

我正在尝试使用Esper Dataflows做一些测试,所以我正在使用Esper Dataflows提供的Select运算符编写一些模式。但是我没有让它工作。我正在尝试使用的代码...

回答 1 投票 0

关于具有esper CEP的match_recognize语法的问题

使用esper进行CEP查询时,我使用match_recognize语法。我注意到,在匹配某些事件之后,它将在以后的比赛中忽略它们。例如,如果使用下面的简单...

回答 1 投票 0

在Esper中计算带有燃烧期的递归EMA

[作为练习,我试图在EPL,Esper中计算带有燃烧期的递归EMA。它具有适度复杂的启动逻辑,我认为这对于评估......>

回答 1 投票 0

esper A事件逻辑和/或B事件epl

要求:1.当A事件和B事件在5秒内到达时,输出C事件2.当A事件或B事件到达时,输出C事件我可以这样写epl:“从A.std中插入C select * :lastevent()...

回答 1 投票 0

ARM Cortex M4中的运行Esper

是否有可能在具有ARM Cortex M4 120 MHz核心的微控制器LPC4088中运行Esper CEP?我想知道是否可以在JVM或Nesper for .NET中使用它。谢谢]]

回答 1 投票 0

为了在运行时部署Esper工作流,必须在Esper 8中使用RMI服务器

我正在尝试制作一个Esper应用程序,该应用程序允许我运行时部署基于数据流的模式。为了实现这一点,我使用了基于RMI的服务器来发送模式,但是考虑到这一点,它...

回答 1 投票 -1

用于计算Esper窗口中所有事件的自定义函数

我想知道将窗口中的所有事件公开给自定义函数的最好或最惯用的方法是什么。以下示例是在...

回答 1 投票 0

在第一个输出之后终止嵌套上下文

我有一个游戏,我正在尝试实施欢乐时光功能,如果您获得一定数量的积分,那么每天在特定时间段内您都会获得一些收益。该事件仅应触发...

回答 1 投票 0

具有OR触发器的两次Esper模式

我有一个Esper语句,例如:从pattern [(A-> timer:interval(100 msec))或timer:interval(500 msec)]中选择...。通常,该语句一次触发或根本不触发,但有时声明...

回答 1 投票 0

Esper EPL在1分钟内匹配5对不同字段值的事件

我有一个事件流,定义如下:create schema Event(id字符串,用户名字符串, ),其中 用于构造上下文,但不直接...] [ 忽略具有相同id字段值的所有事件,这将意味着记住曾经发生的所有id字段值...对吗? 我将通过使中间流具有一个标志来解决这个问题,该标志指示用户名是“输入”还是“保留”当前不同的用户名集合。我将使用该中间流从命名窗口中添加和删除用户名(及其附加信息)。使用“从计数> x的命名窗口中插入结果流选择窗口(*)”选择最终输出。然后使用“结果流”作为触发器删除命名窗口内容,以便这些用户名消失,避免重叠(命名窗口具有中间流的合并)。 这样,您的解决方案便成为两步设计。第一步产生中间物流。当找到5时,第二个保留中间流以供输出。

回答 1 投票 0

在上下文中查询语句的可能输出事件计数

我们正在使用这样的上下文定义,例如私有静态最终String context =“ create context oneHour start(0,*,*,*,*,0)end(59,*,*,*,*,59)”;我们正在使用epConfig.getEngineDefaults()....

回答 1 投票 0

甚至在使用输出速率限制器后,Esper仍在抛出oom

我们正在esper中创建一个每小时的上下文,并将@hint与输出速率限制器一起使用。但是在某些事件中,我们仍然会耗尽内存。 XMX -12 G在某些情况下,如果压缩不好,...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.