我有活动要到esper，我有这个问题 select * from Location match_recognize (
measures A[0] as loc1我搜索并发现我的数据上有四个连续的。我希望查询命中所有的4个。我发现由于缺省跳过子句，当有3个匹配项时，查询会停止。我想要更改该设置，或者找到一个查询，当至少有3个连续的A时命中，当A未命中时停止。
浏览 29提问于2021-09-28得票数 0
回答已采纳
1回答
我正在从事一个项目，其中有一个连续的事件流。有许多并发用户可以创建/更新/删除规则，并在流与这些规则匹配时收到警报。处理这个问题的正确方法是什么？对于这种用例，有没有标准的方法/库？
谢谢
浏览 1提问于2018-05-14得票数 0
我使用Kafka生成器连续向Kafka主题发送CSV行，并生成以下形式的CSV行流：
temp=23.3, pressure=1015, humidity=63.4, windspeed=7.4....现在，我想使用ESPER在这个流上执行复杂的事件处理，但是Esper使用预定义的POJO类并使用EPL语句来过滤事件。如何在运行时将CSV流转换为事件流，以便Esper可以根据某些逻辑提取或过滤参数，如温度或压力(例如，提取在5分钟内变化的参数)？
浏览 1提问于2018-07-24得票数 0
我对这项技术非常陌生，我需要能够准确地按顺序检测发生的事件。例如:a -> b -> c根据这些事件输出事件a -> b -> d ->…-> C将不会基于这些事件输出事件，因为a、b和C事件不是按顺序排列的。
是否可以使用ESPER EPL语句。
浏览 0提问于2019-10-08得票数 0
模式匹配算法是规则引擎或复杂事件流处理引擎中的主要算法。在我学习的过程中，drools规则引擎使用rete算法进行模式匹配。像siddhi，FlinkCEP和Esper这样的复杂事件流处理引擎是做什么的。我在网上浏览了一下，没有得到任何关于这方面的信息。请让我理解在CEP和规则引擎中使用的模式匹配。
浏览 9提问于2018-01-25得票数 1
如果我不尝试引用第一个匹配事件(EventA)中的属性，而只是尝试将属性从EventB传递给myFunction，那么它就可以正常工作。我得到的错误是：at com.espertech.esper.core.service.EPRuntimeImpl.processWrappedEventCaused by: java.lang.ArrayIndexOut
浏览 2提问于2015-11-06得票数 0
1回答
简单的事件序列
、、
假设正在发出A、B、C或D类型的事件。我想要检测A类型的事件之后是B类型的事件。换句话说，我想检测一个序列，对于这个序列，Esper的EPL提供了->运算符。然而，我上面描述的是模棱两可的，我想要的是:每当检测到B时，我希望它与最新的A匹配。我一直在玩弄EPL的语法，但我能想到的最好的方法是：但是，这会将每个B与最后一次匹配后出现的最旧的A进行匹
浏览 23提问于2016-08-02得票数 0
回答已采纳
1回答
我正在尝试将订阅者附加到Esper中的事件，但我想为此使用.epl文件。我一直在浏览存储库，我看到了通过使用注释接口来实现这一点的例子。但是，如果我用Java设置订阅服务器，它就能工作。/schema/esper"
import c
浏览 6提问于2017-12-26得票数 0
回答已采纳
我使用的是esper，当我用timer:interval(10秒)查询我的命名窗口时，我每隔10秒就会得到相同的事件。我不会输出窗口中出现的其他事件。这是EPL on patternevery计时器:间隔(20秒) select DeviceIP，parent，child，Supress，Status from testZabbixProblem“
浏览 1提问于2014-10-20得票数 0
2回答
我使用Esper根据激发的esper查询生成警报消息。<?我对事件获取触发器的要求如下: 1.如果日志消息中类型= "b2c_access“的响应字段为= 302，并且该响应代码在1分钟内的日志消息计数大于10，则触发一个事件。我有下面的EPL
select * from b2cAccessLogEvent(type="b2c_access").win:ti
浏览 0提问于2013-11-26得票数 0
回答已采纳
我是Esper开发的新手，我有一个小问题。在SQL中，我有以下要转换为Esper的查询: select max(time) from tab group by user
我想要做的是，对于我拥有的所有事件，我希望为每个用户选择最大(时间)并显示它在Esper中，我将其翻译为: select max(time) from window group by user。但是，与SQL不同的是，窗口中的每个事件都会显示出来，所以我最终在控制台中获得了每个用户的所有时间值，而不是最高值:/
浏览 0提问于2014-10-31得票数 1
我的目标是与发布者和使用者一起创建一个分布式应用程序，在其中我使用CEP处理数据流，以生成事件使用者的事件通知。我很困惑，我以为Esper提供了同样的功能。
浏览 8提问于2017-03-07得票数 3
回答已采纳
在我们现有的应用程序中，我们使用Esper版本5.3。我们添加了一些addPlugInSingleRowFunction()来在EPL中使用它，如下所示--但是，一旦调用sendEventBean()方法将事件发送到运行时令人惊讶的是，
浏览 0提问于2020-06-01得票数 0
我正在寻找一种方法来确定具有时间事件属性的两个连续事件之间的时间差，其值为: 2016-08-25T13:05:06.953391Z。这里最好的方法是什么，我需要为事件模式使用什么样的类型。在使用Esper时，我尝试使用Long或Date，但随后得到以下错误：在表达式“create (符号字符串，价格加倍.(63个字符)”中失败:错误开始语句:可嵌套类型配置遇到一个意外的属性类型名称预期的java.lang.Class或java.util.Map或以前声明的Map
浏览 0提问于2016-08-26得票数 0
回答已采纳
2回答
Esper和EPL在一般情况下都是新的，我有两个用例，它们基本上是相互对立的。首先，我需要使用firstunique(*parameters*).win:time(*time*)捕捉时间窗口中的所有唯一事件。现在我要做的正好相反，基本上捕捉到到达窗口的所有事件，这些事件没有被那个语句抛出，基本上是所有的重复事件。
我怎样才能做到这一点？谢谢！
浏览 3提问于2017-07-06得票数 0
回答已采纳
我正在使用Esper5.0，需要对关系数据库中的数据执行查询。在我的例子中，这是一个通过JDBC连接的MySQL数据库。现在，我想对数据库中的数据制定一个EPL查询。some user inputString query我想出了四个想法：
使用EPL替换参数的：不工作，因为在SQL表达式中Esper不支持它。Esper
浏览 0提问于2014-08-12得票数 0
2回答
我们有一个事件流，每个事件具有以下属性： private String id; privateString dst;此外，我们还有一组分层或嵌套的规则，我们希望用EPL和Esper来建模。如果并且只有当所有父规则都已被激活时才应用每个规则(所有这些规则都发生了匹配的实例)。100 or more with src, dst the same as the src, dst in
浏览 4提问于2013-08-06得票数 0
回答已采纳
1回答
我是Esper的新手。有人能帮助我定义EPL语句，以便在发生以下情况时捕捉事件：我如何定义语句来捕获它？纳苏
浏览 2提问于2020-10-07得票数 0
1回答
我试图使用套接字向esper发送一个avro事件。我正在使用在EsperIOSocketAdapter中描述的类，它可以很好地处理POJO事件和Map，但是我无法使它与avro一起工作。，所以基本上我需要向EsperSocketAdapter.发送一个由Avro表示的事件。我用的是Esper 7.1.0
这是我的Esper intialization，我使用一个名为"PersonEvent“的事件，其中包含两个字段，类型为String的&qu
浏览 1提问于2018-12-29得票数 0
1回答
我正在评估Esper作为一个无损处理帐单数据的系统。预计系统每秒可以处理大约20000个事件，并通过连续聚合运行大约400个语句(不在内存中存储事件)。为了获得预期的性能，我已经开始在多线程中发送事件，并发现esper经常丢失数据。;import com.espertech.esper.client.EPRuntime;
importcom.espe
浏览 1提问于2018-04-10得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号