问题标签 [esper]

我正在尝试使用 select 语句，其中字段的值取决于来自 2 个窗口的值。最后还使用 where 语句从 1 个窗口中过滤掉事件。例如。

问题是即使没有匹配项，我也想输出事件。这样B流被视为null。

I'm following a tutorial http://www.javacodegeeks.com/2012/03/twitter4j-and-esper-tracking-user.html. But when I'm trying to compile the project it gives me follwoing error:

I have added the relevant jars esper-4.9.0.jar, antlr-3.0.1.jar, twitter4j-core-2.2.6.jar. Please help me in resolving errors as I have done lot of google but there is as such no solution found.

我想通过 ActiveMQ 'Queue' 向 WSO2 CEP 发送事件。我还想接收 WSO2 CEP 处理的 ActiveMQ 'Queue' 中的事件。我想知道 Esper Engine 是否可以做到这一点？

我正在使用 Java 中的 Mongo 和 Esper。一旦我启动了 esper 服务器，我就开始添加文档，并且在我的一个监听器中我必须更新其中的一些文档（每次一个）。问题是 Mongo 仅在我启动服务器之前在数据库中更新这些文档，但如果我刚刚插入它们则不会。

我正在运行这段代码：

有谁知道会发生什么？如果您需要任何其他信息，请告诉我。

非常感谢。

问题很简单：使用 Esper 引擎从 2 个不同的流中只提取不存在的记录。
ID 存在于 streamA 中，但不存在于 streamB 中。

在 SQL 中，它看起来像这样：

我已经尝试过 Esper 风格，但它不起作用：

可悲的是，如果 stream_A.Id 在 stream_B.id 之前插入，它将回答查询条件并且查询将不起作用。

关于如何使用 Esper 识别“ID 存在于 streamA 但不在 streamB 中”的任何建议？

我们将 Esper CEP 引擎（基础版）用于我们的 BI 解决方案。我还想将事件持久化到 Oracle。Esper 有一个单独的企业产品 EsperHA，它提供了这个功能。Esper HA 是成熟的 HA 产品。我们只需要事件持久性，以便其他应用程序可以直接或通过 Esper 使用该数据。是否有任何基于 Java 的 EsperHA 类型功能可用的开源实现？我找不到一个。基本上，我正在寻找基于 RDBMS 的时间序列数据库，它为 Esper 透明地提供事件持久性（无需像在 esper EPL 中那样编写任何 sql 查询/嵌入 sql）。

以下是我们的 Esper EPL 声明：

想知道如何在上面的查询中遍历所有数组元素（上面的 'inputCounts' 给出数组大小），而不是像上面的 EPL 那样只获取一个数组值。

对此的任何帮助将不胜感激！

苏尼特。

使用esper或者nesper我可以直接从运行时发出事件，如下所示：

或者我可以像这样使用自定义事件发送器：

我已经尝试过计时，看起来自定义事件发送器可能会更快，尽管它似乎与我所看到的并没有太大的性能差异。

是否有令人信服的理由选择一种方法而不是另一种方法？

如果我使用 custom 的第二种方法，EventSender缓存EventSender我从运行时获得的内容是否安全，这样我就不必每次都查询它？

对于满足规则的事件，如何在监听器中获取相关的滑动窗口（ID/名称）详细信息。

例如，我们有规则 -

我们接收 StockTick 事件 A、B（作为滑动窗口 1 的一部分）。

事件 B,C 作为滑动窗口 2 的一部分（作为滑动窗口 2 的一部分）。

事件 A 是滑动窗口 1 的一部分，事件 B 是窗口 1 和 2 的一部分，事件 C 是滑动窗口 2 的一部分。

现在，对于每个事件 A、B 和 C（B 在侦听器中被接收两次），我如何在侦听器中找到与事件 bean A、B 和 C 关联的滑动窗口（1 或 2）。

我使用了 UpdateListener 和 StatementAwareUpdateListener。我无法获得有关与事件 bean 相关的滑动窗口的信息。

我想在 esper 中记录数据处理时间，我选择布林带作为示例。在布林带中，称为移动平均线 (MA)。该 MA 从计算股票价格平均值的结果中获得。在这种情况下，我设置了 win:length(20)。因此，可以从数据窗口视图中存在的 20 个事件计算股票价格平均值的结果中获得 MA。以下是我创建的代码。

从上面的代码中，如果计算了平均值，将记录时间。但我需要的是我希望记录第 20 个事件和下一个事件进入数据窗口视图时的时间。它是从布林带计算结果中获得的开始时间和结束时间。我的问题是如何记录第 20 个事件的时间，并同时将下一个事件输入到窗口视图数据中。请帮忙