esper

0热度

1回答

我在流处理和复杂事件处理方面做了一些研究。我想用一个开源软件来处理Apache的Storm。我发现CEP引擎像Esper ，Siddhi，Sase +，但我正在寻找一些专门针对Apache-Storm的工作。是否有任何可以在Storm上完美调整的CEP引擎，以及引擎的内部体系结构（例如在1个螺栓或其他内部工作）。任何信息是最受欢迎的。

0热度

2回答

Esper - 使用命名窗口的冗余输出

我是Esper的新手，并开始使用EPL Online进行测试。当我创建一个命名的窗口并向其中插入事件时，我从两个语句中获得重复的输出。例如：创建窗口OrdersNamedWindow.win:keepall（）as OrderMapEventType; 插入到OrdersNamedWindow select * from OrderMapEventType; 是否有办法从两个语句中重复删除输

0热度

1回答

esper旧事件1与.win：时间或长度属性

在esper中，当我试图使用.win打印旧事件：长度或时间窗口属性，那么我只得到一个旧事件和一个新事件。这是可能的？，同时使用time_batch和length_batch，我收到预期result.e 查询：选择irstream *从StockEvent.win:length(5）输出快照： Output snapshot:

0热度

1回答

与名为Windows埃斯佩尔输出条款

我有一个关于使用输出子句结合命名的窗口，模式和INSERT INTO语句的问题。我的目标是检测不存在的事件，将其存储在一个名为窗口，当事件再次开始来选择并删除该行并用其作为一种“在线”指示灯（见Esper - detect event after absence）不知何故，我希望能够限制在短时间内发生多个离线 - 在线事件时的事件发生率（禁用误报）。我认为输出子句可以在这里帮助，但是当我在插入

0热度

1回答

艾斯波 - 不存在

我发现，有可能使用例如，以检测不存在事件之后检测事件： SELECT * FROM图案[每EventX - >（定时器：间隔（10秒），而不是EventX）] ，但它是否也可以在缺席之后检测到事件的存在？也许事先使用？是否有可能使用一个语句来检测缺席和在场？在此先感谢！

0热度

1回答

Esper - 我们可以使用esper进行流水线时尚处理吗？

我想用流水线的方式使用Esper进行一些事件处理。我需要为每个事件检查多个案例。例如，假设我想针对以下情况运行我的传入数据。我会怎么做？做这件事的最好方法是什么？壳体1 =“如果当前电平比平均最后5倍连续的值的较大的400％，则标记与异常-1事件” 壳体2 =“如果当前电平值是空然后标记为例外-2" 情况下3 =‘如果案例2和案例3不匹配，那么数据被标记为‘安全’’ 以下是我想做的事情表示粗糙

0热度

1回答

旧事件的存储如何影响esper的性能？

旧事件的存储如何影响esper的性能？例如 - 如果我们存储10个旧事件，会对性能产生什么影响，如果我们存储100个旧事件，性能会发生怎样的变化。会有什么变化吗？我想知道esper中的内存使用情况。旧事件存储在哪里？

0热度

1回答

简单事件序列

假设正在发射A，B，C或D类型的事件。我想要检测何时类型A的事件之后是类型B的事件。换句话说，我想检测一个序列，对于这个序列，Esper的EPL提供了->运算符。不过，我上面描述是模糊的，我想是这样的：当检测到B，我希望它与最近A. 我已经与英超的语法玩弄匹配，但我能想到的最好的是： select * from pattern [(every a=A) -> b=B] 但是，这会将每个B与最

0热度

1回答

属性“价格”不适用于写入访问

执行更新操作时出现以下错误：属性'价格'不适用于写入访问。 updateStatement： update istream FaultyStream set price = 100 where id = 7; 我的事件类实现java.io.Serializable。仍然无法执行更新。

0热度

1回答

日期对象的Esper算术运算

我正在寻找一种方法来确定具有时间事件属性的两个连续事件之间的时差，如下所示：2016-08-25T13：05：06.953391Z。这里最好的方法是什么，我需要什么类型的事件模式。当在线使用艾斯波EPL我曾尝试使用长或日期，但后来我得到以下错误：请检查EPL模块文本部署在表达“创建模式StockTick失败（符号串，价格doubl。 ..（63个字符）'：错误开始语句：嵌套类型配置遇到属性'时