Invoke方法，一旦所有包含事件

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

我认为你正在寻找“订户”。

Subscribers in doc

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