超能力。无法在侦听器中接收删除事件

Question

在 Esper 中使用 Time windows 时，window 中的旧事件或已删除的事件将作为输出发送到附加到语句的 UpdateListener。根据文档，这是应该发生的情况。但是当我执行如下代码时，它在 oldEvents 中没有任何事件，即使是新的滑动 window 开始。它甚至发生在长度 window.

EPStatement statement1 = epAdmin.createEPL("select current_timestamp, sum(price)" + " from StockTick.win:time(5 sec)");

statement1.addListener(new UpdateListener() {
        @Override
        public void update(EventBean[] newEvents, EventBean[] oldEvents) {
            System.out.println("sum \t" + newEvents[0].getUnderlying() + "\n");
            System.out.println("old sum \t" + oldEvents[0].getUnderlying() + "\n");
        }
    });

当我将事件发送到此查询中时，UpdateListener 会在 newEvents 中获取进入 windows 的 newEvents，但是当事件从进一步滑动中移除时 windows，它应该存在于 oldEvents 中，但我做到了不要将任何事件放入其中。

我在构造监听器或语句时有没有做错。

Answer 1

默认情况下，引擎不会输出删除流，除非 select 子句具有 "irstream"。

select irstream current_timestamp, ....

超能力。无法在侦听器中接收删除事件

Esper. Unable to receive remove events in listeners

event-listener

event-handling

esper