问题标签 [esper]

我有一个元组：

我创建了两个 esper 语句 EPL：

事件流在配置中注册。

我面临的问题是，在发送的两个事件中.. 一个作为状态 = -1，另一个作为状态 = +1，我在第一个 EPL 语句中得到 +2 的增量计数。

但是，如果只发送一个事件，则流可以完美运行。有什么我在这里想念的吗？

假设我对创建的 Esper 视图有一个单独的侦听器。

有没有办法在规则完成之前获取 esper 核心中最后插入的事件？

现在对于事件插入，我正在使用此示例代码

任何帮助将不胜感激。

我正在使用 Esper + Mule，我正在尝试定义一个 POJO 和一个事件，但是在阅读了 Espero 的文档之后，我还没有找到我真正需要的东西。

我的事件由 POJO 表示，具有如下属性：

我想做的是使用关键字 IN 将其与另一个单词列表进行比较，因此模式如下所示：

但我得到这个错误：

有什么办法可以做到这一点？

非常感谢

我将 Esper 4.9 与 Mule 3.4 一起使用。我有一些不同的模式来处理股票报价。在某些时候，它们都运行良好，没有任何理由（我真的不知道我是否只能看到来自 Esper 的日志），Esper 不再处理更多事件，尽管它们正在发送给它。

正如我所说，我没有这方面的日志，因为我只有 Mule 日志，但没有来自 Esper 的任何日志。但如果需要任何其他信息，我将能够提供。

我没有使用 Mule Esper 连接器，因为我无法让它工作。

有没有人遇到过这个问题？

非常感谢

我是 Java 复杂事件处理框架 Esper 的新手。目前我正在使用以下查询：

我还想在 180 秒窗口中获得第一个柱的高点和最后一个柱的低点。任何想法我怎么能做到这一点？

我有一个非常基本的 Esper 问题，Esper 中的 OUTPUT WHEN 和 WHERE 关键字之间的基本区别是什么。这是我使用这些关键字的示例。

和

我无法解决 Esper 中的某个问题。我必须检查当前的 Tick 值是否从昨天的 Max Value 上升。这是每 24 小时返回最大值和最小值的代码。

我必须在多个证券上运行它，所以我必须检查每个证券。

我无法解决 Esper 问题。我必须计算 24 小时的最大值和最小值，然后我必须检查价格是否高于这个值（这必须在多个证券上完成。）这是我正在使用的代码。但是我打赌很多性能受到打击，并且不止一次触发了一个事件。

我该如何改进此代码？

目前我正在使用以下代码。它查找 ValueTrigger 的第一个事件并将其保存并忽略所有下一个 ValueTriggered 事件。然后它将 currentData.last 值与第一个 ValueTriggered 事件进行比较。

我想要实现的是在条件匹配时休息 triggerPoint 的值。我想用一些函数更改 std:firstevent() ，该函数在“where”条件匹配时重置值（通过重置我的意思是下一个 ValueTriggerd 值）。

我是 esper 引擎的新手，我不确定多个流的含义。我想创建这样的东西：

事件生成器类定义如下：

控制器是保持 epruntime 发送事件的多线程单例。在 CepEngine 类中，我还有用于监听事件的 EPL 语句。这是多个事件流的好含义吗？

谢谢