问题标签 [nesper]

I've got an esper query for pulling market data. It looks like

This will fire when ever a new quote occurs. I require a first quote/event to do some initial setup. This is no problem for symbols where events/quotes fire every second but for some symbols you won't get a new quote event for a minute.

Working under the assumption that there have been quote events before this expressions is setup. Is there a way to force output when the expression is first parsed? ie is there a way to say, give me the last event when the expression starts?

I would like to measure the time of cars with an unique Id with NEsper. My problem is, that there are several cars on a road. This road has predefined steps. I want to start to stop the time for every unique car that is in first step until this car receives the last step.

The problem is, that I don't know how to separate the cars with a given Id. In this example, if one of the cars receives the last step the event does not fire anymore.

我正在尝试按用户对事件进行分组并分批返回它们（每个用户）。例如，如果 3 个用户每人发送 5 个事件，我希望从 esper 输出 3 批 5 个事件。

使用以下 EPL，我能够验证是否创建了 3 个数据窗口，并且每个窗口中都有 5 个事件。

select * from EVT.std:groupwin(User).win:time_batch(2).std:size()

但是，当我删除 std:size() 时，它会在一批中返回所有 15 个事件。据我了解，这是由于 std:groupwin 分组窗口视图如何被 std:merge 视图评估。

如何从每个数据窗口输出批处理事件而不将它们全部合并在一起？

假设我有一个简单的对象：

我应该如何修改以下查询以使用 StockTick.date 或 StockTick.unixTimestamp 在 .win:time() 窗口内聚合？

让我们考虑一个在 SQL 数据库中具有相同表示的简单对象，其属性（列）：Id、UserId、Ip。

我想准备一个查询，如果一个用户在 1 小时内从 2 个 IP 地址（或更多）登录，则会生成事件。

我的 SQL 看起来像：

转换为 EPL：

例外：

附加信息：第 1 行第 100 列的 '(' 附近的语法不正确，请检查保留关键字 'select' 附近的 from 子句中的外连接

更新：

我成功地创建了一个名为 window 的模式并将数据插入其中（或更新它）。我想在新的 LogEvent 到达 .win:time(10 seconds) 时增加计数器，并在事件离开 10 秒窗口时减少它。不幸的是，当事件处于删除流中时， istream() 似乎没有提供真/假。

有什么我错过的吗？

我确信这句话在 Esper 中有效：

但是此语句会引发错误：

错误信息：

然后我使用 JOIN 但它仍然不起作用：

错误信息：

如何在 Esper 中连接两个表？

我正在构建一个 Nesper 应用程序，部署后它会抛出此错误：

Esper提供了一个线性回归函数 [stat:linest( , )]。

示例看起来像（这很好用）：

但是，我试图对按符号（例如，INTC）分组的窗口中的所有数据进行线性回归，但它不允许我这样做。我尝试使用“有符号='GE'”，但这也不对。这是我试图做的事情：

任何解决此问题的帮助表示赞赏。

我在 esper 中创建了一个 std:unique(Id) 窗口，如

我所期望的是，在每 60 秒结束时，我将获得所有数据行的列表：

相反，我得到的只是最后一行（Id：3 Rate：22）。我还尝试了“全部快照”，但这也无济于事。

有没有办法生成在 60 秒窗口内发生的所有事件的结果集，该事件由 Id 唯一 - 只是最近的事件？

当您在句子中使用@Audit 注释时，如何/在哪里可以找到 nesper 中的@audit 信息？我已经配置

我使用日志来写其余的信息。

但我什么也没看到。我试过 esper 和 java，我看到了信息。有什么例子吗？

提前致谢，