我有兩種事件類型(A和B)。我想寫一個模式,它檢測到每個B事件後A事件與相同的ID:every A -> B (A.id = B.id)。但是,它應該是不同的ID。換句話說,該模式應該忽略在第一個事件之後具有相同ID的所有事件,直到上述表達式爲真,意味着B具有相同ID的事件發生。 例如,假設這是一個事件流: 1. A (id: 1); 2. A(id: 2); 3. A (id: 3); 4. A
我最近一直在使用Esper,並且有一個我在文檔中遺漏的功能,但它可能存在。 我想存儲一些事件,直到沒有人彈出15秒,當它發生時釋放他們。 一個查詢正是這麼做的,它是: select rstream * from MyEvent.win:time_accum(15 sec)
我可以在MyEvent添加條件像 select rstream * from MyEvent where status =
我EPL很簡單: 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)