esper

    0熱度

    1回答

    我使用Esper的開源版本來執行一些複雜的事件處理。我正在使用Esper + Storm的組合,以便我可以在分佈於整個網絡中的Storm bolt中編寫我的CEP邏輯。 Esper還提供高可用性的HA版本。我的問題是使用Esper HA而不是使用Esper(開源)+ Storm組合的優點是什麼。

    0熱度

    1回答

    我正在使用ESPER從CSV文件讀取事件。 如何在讀取CSV文件完成時使查詢輸出成爲可能。 例如,我想輸出每30分鐘,或在文件的結尾 SELECT id FROM stream output every 30 min or [ EOF reached ] 預先感謝 問候

    0熱度

    1回答

    我敢肯定,這種說法作品在艾斯波: /* query from table TableA when receive event PriceEvent */ ON PriceEvent p SELECT a.SymbolA, p.price FROM TableA a WHERE a.Symbol = p.Symbol 但這一說法引發錯誤: /* join table TableA wit

    0熱度

    1回答

    我想知道這是如何使用艾斯波的引擎(V5.0.0)可以配置引擎實例,這樣他就可以在Java客戶端應用程序連接到關係數據庫,比如說pgSQL。 這是寫能夠從數據庫(5.13. Accessing Relational Data via SQL)加入具有靜態/歷史數據事件流(或數據流)EPL查詢必需的。也就是說,要從數據庫中讀取數據。 (寫入數據庫需要EsperIO adapter的使用。) 從Espe

    -1熱度

    1回答

    我是esper epl查詢的新手。我想知道是否可以在運行時更改EPL查詢。這意味着我有一個可用於更改ESPER中的時間長度,記錄數的表單。它就像這,增加在epl查詢的時間長度,在事件中的記錄數。同樣我想以實用的方式改變參數。我想知道這是可能的,如果是的話,給我一些提示開始。 謝謝

    0熱度

    1回答

    我的老闆想讓我學習CEP的開源庫Esper,所以我需要一些幫助。 我想許多UpdateListener訂閱一個事件流,並且它們同時運行。也就是說,如果一個監聽器有一個長而大的進程,那麼其他監聽器就會運行併發,因爲我們在短時間內有很多事件,所以我需要更快的處理。

    0熱度

    1回答

    使用Esper引擎編寫連續查詢,是否有可能生成訂購具有(額外)「列」/屬性的事件批處理指示事件有序位置? 想象一下以下艾斯波的查詢: SELECT id, val FROM Datastream.win:length(10) OUTPUT SNAPSHOT EVERY 1 EVENTS ORDER BY val DESC 舉

    0熱度

    3回答

    我正在使用Esper來彙總我的傳感器數據。數據可能以任何間隔到達,即1秒到120秒。每個數據點包含TimeStamp和Value。 我希望30分鐘窗口中的最小時間戳,最大時間戳,平均值和數據點數。 30分鐘窗口的起點和終點是固定的,即01:00到01:30,01:30到02:00等 我怎樣才能用Esper來實現這個?

    0熱度

    1回答

    我使用ESPER 5.1.0在Java上運行日誌事件(發件人,消息)分析。我想爲每個發件人尋找特定的消息模式。 我打算通過定義context做到這一點。我設法創建EPContextPartitionAdmin,但我不明白怎麼和其中我需要創建實際的上下文。 有什麼樣.createEPL()的上下文定義?或者我在這裏錯過了一個觀點。

    1熱度

    1回答

    我有有2個屬性OrderEvent類: ItemName字符串,雙價 我的要求是:ESPER框架將舉行OrderEvent對象10秒。爲了這個,我下面寫EPL查詢: 選擇ITEMNAME,總和從OrderEvent.win:time_batch(10秒(價格)).STD:唯一的(ITEMNAME)組由ITEMNAME 這是工作的罰款。 但我想每隔1秒運行一次上面的查詢,並顯示所有項目名稱和總和(價