【问题标题】:Esper window usage: Recalculation based on event leaving windowEsper窗口使用:基于事件离开窗口的重新计算
【发布时间】:2012-12-18 21:11:51
【问题描述】:

我需要这样的东西。

//Create a named window (w1)
Create window w1....

//then insert events into window
insert into w1....
select amount,.....
from....
where...

//remove from window
on RemoveEventArrived as r
Delete from w1
where w1.id = r.id

现在从名为 window 的 w1 插入另一个事件

//inserting into final output event
insert into derivedevent
select sum(w.amount)
from w1 as w

suppose event sequence:
1. Event with id=1 and amount= 100 arrived.
   o/p of sum(amount) triggered and gives 100.

2. Event withid = 2 and amount=200 arrived.
  o/p of sum(amount) triggered and gives 300.

3. **Remove** Event with id=1 arrived.
o/p of sum(amount) triggered and gives 200.

4. Event with id = 3 and amount=500 arrived
o/p of sum(amount) triggered and gives  700

但有些第三个事件无法自动触发派生事件重新计算。
第 4 个事件的到来触发并根据需要提供输出。
有什么标准的做法吗?

我想计算一个新事件是进入窗口还是离开窗口的总和。

【问题讨论】:

    标签: java esper complex-event-processing


    【解决方案1】:

    3. 事件(删除)确实会通过“插入派生事件”触发新总和的输出,除非没有删除任何内容,因此您的 id 键可能是错误的。 如果仍有问题,请向 esper 用户邮件列表发送一个最小的测试用例。 或者使用@Audit 查看引擎在内部对每个语句做了什么。

    【讨论】:

    • 我已经更新了问题,请查看。特别是第四个事件根据需要提供o / p。
    • 我遇到了同样的问题。如果您找到了解决方案但尚未发布,请分享。谢谢
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2023-04-08
    • 1970-01-01
    • 1970-01-01
    • 2018-10-11
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多