esper - 在缩略图窗口中调用一次方法，但输出所有包含的事件

Question

我怎样才能调用像这样的方法

select udf(a,b) from Event.win:length_batch(5)

并再次打印大小为 5 的窗口。假设我发送以下事件：

runtime.sendEvent(new Event(1,2));
runtime.sendEvent(new Event(3,4));
runtime.sendEvent(new Event(4,2));
runtime.sendEvent(new Event(6,8));
runtime.sendEvent(new Event(4,6));

并在批处理后以相同的顺序打印出来。这意味着调用的方法 udf(a,b) 每批只能执行一次。我使用了 updatelistener，但我必须将它作为方法事件调用，尽管我可以使用侦听器获得所需的结果。

谢谢。

Answer 1

我认为您正在寻找“订阅者”。

doc 中的订阅者

public void update(Event[] rows) {...}