我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)
我正在嘗試批處理這樣的通知事件,並且我正在通過一個通知事件獲取一個Notifications事件。誰能幫我? 提前提醒。 相關聲明 INSERT INTO Notification SELECT d.id as id,a.stationId as stationId,d.firebaseToken as firebaseToken, d.position as devicePos,a.locati
我最近一直在使用Esper,並且有一個我在文檔中遺漏的功能,但它可能存在。 我想存儲一些事件,直到沒有人彈出15秒,當它發生時釋放他們。 一個查詢正是這麼做的,它是: select rstream * from MyEvent.win:time_accum(15 sec)
我可以在MyEvent添加條件像 select rstream * from MyEvent where status =
(1)我需要將Esper數據庫適配器連接到我的項目。使用this 爲指導IM,但我不知道在哪裏可以找到的配置文件,因爲即時得到這個錯誤:Cannot locate configuration information for database 'db1' 這是我 public class Esper {
public void iniciar() {
EPServiceProvide