esper

0热度

1回答

@POST @Path("/minPrice") @Consumes(MediaType.APPLICATION_JSON) public String minPrice() { String userQuery = "select min(price) from MyEventClass"; String userFileName = "MyInputFIle.csv"

-1热度

1回答

Nesper在使用win窗口时CPU /内存使用率高：时间

我使用Nesper作为CEP引擎来处理我的应用程序中的事件。我想下面的EPL声明型号：事件的Value场的平均值在有限窗口时间。如果这些平均值中的任何一个匹配了1期望值，则会生成一个事件。我此建模为： SELECT ( (AVG(ParameterEvent1.Value) = 1) OR (AVG(ParameterEvent2.Value) = 1) ... (AVG(Param

0热度

1回答

如何设置Esper使用单线程

我想完全在单线程中使用Esper。我有以下配置： config.getEngineDefaults().getExecution().setDisableLocking(true); config.getEngineDefaults().getThreading().setInternalTimerEnabled(false); config.getEngineDefaults().getTh

2热度

2回答

Esper模式定时器：interval（）不起作用

我有这个基本的POC代码。我可以看到发布的事件，但没有听到任何警报。在下面的代码中，没有任何语句pattern1或pattern2获得警报。 Config的setInternalTimerEnabled默认为True，但我试图在代码中设置True，但仍然是同样的问题。我错过了什么吗？任何线索都会非常有帮助。 public class PatternSimpleQue { publ

0热度

1回答

单个规则中的多次重复

我试图在EPL中表达规则“至少两个foo”，接下来是两秒内的两个bar“。我试过使用这两种模式和match_recognize，我不能得到我想要的语义。我修改了在线EPL工具中的StockTick示例来说明我在做什么。我已经试过以下两种模式： select g[0].seq, g[1].seq, g[2].seq, g[3].seq, y[0].seq, y[1].seq from patter

0热度

1回答

Force Esper使用某些ScriptingEngine来解析方言

Hey Esper专业人员！有没有一种方法/或解决方法，允许我强制Esper依赖某个脚本引擎（比如说Mozilla Rhino）处理所有表达式？首先，我知道我们可以配置Esper的默认方言。例如，如果我们将默认脚本引擎配置为犀牛，如 config.getEngineDefaults().getScripts().setDefaultDialect("rhino"); 表达式像concat(st

0热度

2回答

lastUnique（）的对面

一般而言，对于Esper和EPL来说，我有两个用例，它们基本上是相互对立的。首先，我需要使用firstunique(*parameters*).win:time(*time*)来捕捉时间窗口中的所有独特事件。现在我需要做的是完全相反，基本上捕捉所有到达该窗口的事件并且不会被该语句抛出，基本上都是重复的。我该如何做到这一点？谢谢！

0热度

1回答

Esper放弃事件

我有一个利用Esper的平台。但是，所有事件都会插入到事件表中并发送给Esper进行处理。我的规则仅针对数据集的10％左右，但通过引擎发布的90％其他数据会瓶颈我的警报。有没有办法告诉Esper放弃我不关心摄取的事件，所以我有一个更小的流通过实际的警报/规则处理引擎？

0热度

1回答

尝试使用艾斯波Lambda表达式

我试图从艾斯波文档的where枚举法为例扩大，并有问题。这里是有问题的例子： select items.where(i => i.location.x = 0 and i.location.y = 0) as zeroloc from LocationReport 我想要做的事似乎很简单。相反，选择items匹配这个表达式的：我想选择包含至少一个item该表达式匹配LocationRepo

0热度

1回答

为什么不能使用此上下文？

我想要在下面两个上下文中指定的时间之间选择相同的语句。但是我没有输出。当B处于活动状态并且C在单个语句中使用嵌套上下文处于活动状态时，如何获得输出？ create context A context B start (0, 12, *, *, *) end (0, 18, *, *, *), context C start (0, 20, *, *, *) end (0, 23