2017-09-25 57 views
0

我EPL很简单:超能力分组输出多个newEvents

select symbol, sum(price) from MarketData(symbol!='').win:time(5.5 sec) group by symbol 

监听器:

update(EventBean[] newEvents, EventBean[] oldEvents) { 
    System.out.println(newEvents.length); //sometimes it's greater than 1 
} 

我认为这是不可能的newEvents.length> 1为我的EPL。

有人可以解释这对我吗?谢谢

回答

0

纠正对于您发布的EPL,始终存在“newEvents.length = 1”,前提是侦听器不会接收其他输出,并且值当然是不可变的。

+0

我打印newEvents并发现,当newEvents.length = n时,eventBean.get(“symbol”)输出n不同的符号。我不知道为什么它会一次触发不同的符号(一个事件) – bylijinnan

+0

提供一个简单的测试类 – user650839