esper

    0熱度

    1回答

    我把數據轉換成艾斯波與類型: {"symbol" :string "price" :double} 我想有一分鐘的價格從每分鐘的象徵。當我做這樣的事情: select min(price), symbol from Market.win:time_batch(60 sec) 我得到了很多與同價位(最低報價),但不同的符號事件(我想只有一個符號有(每分鐘)只有一個事件和價錢)。

    0熱度

    1回答

    我想知道Esper是否提供了一種機制來發現與接口實現關聯的所有EPStatement對象。 EPStatement和UpdateListener之間的關聯是單向的(從EPStatement到UpdateListener),並且我無法在API或參考文檔中看到是否有方法可以發現給定UpdateListener的EPstatement對象,還是我必須自己維護這種跟蹤?

    0熱度

    2回答

    我有一個提取市場數據的esper查詢。它看起來像 select * from L1Quote(Symbol='MSFT') 這會在任何時候發生新報價時觸發。我需要第一個報價/事件來做一些初始設置。對於每秒鐘觸發事件/引號的符號而言,這不成問題,但對於某些符號,您將不會在一分鐘內得到新的引用事件。 在設置此表達式之前已經有報價事件的情況下工作。 當表達式第一次被解析時,是否有強制輸出的方法?即有

    0熱度

    3回答

    我必須在ESPER中定義下面的類,以便能夠引用子類型和內部數組。我必須務實地做到這一點。我並不怎麼在意: UPDATE:完整的類: public class IoTEntityEvent implements java.io.Serializable { private IoTProperty[] Properties; private String About;

    0熱度

    2回答

    我使用艾斯波(事件處理引擎),英超查詢: select * from Event.ext:time_order(timestamp_event, 10000 minutes) where duration > 10 但輸出不受「timestamp_event」下令: id int = 1, timestamp_event= 1412686800000, duration = 30 id in

    0熱度

    1回答

    我試圖用Esper運行一個簡單的測試(第14章,http://dl.e-book-free.com/2013/07/activiti_in_action.pdf)。該代碼非常簡單: public class EventLengthWindowTest { public class LoanRequestEvent { public int amount =2; pu

    0熱度

    1回答

    我正在使用ESPER進行流事件處理。我正在創建語句,然後將它們添加到CEP引擎中,如下所示。這是處理大量數據(每分鐘百萬個事件)的正確方法嗎? cepRT.sendEvent() 如何ESPER映射事件查詢,它必須進行評估: Configuration cepConfig = new Configuration(); cepConfig.addEventType("StockTick

    0熱度

    1回答

    我正在使用esper,當我用計時器查詢我的命名窗口:間隔(10秒)時,我每10秒鐘都會得到相同的事件。我不輸出窗口中的其他事件。 這裏是上圖案的EPL [每隔定時器:間隔(20秒)]中選擇DeviceIP,父母,子女,剿,從testZabbixProblem狀態」

    0熱度

    1回答

    Im在ESPER中遇到問題。 我有一個模擬的股票文件,conatins很多信息。 當BTC股票的加權價格上漲超過100倍時,我想找到所有的開始和結束日期。 這是文件的外觀。這些個股BTC: 2010-07-18,0.04951,0.08585,0.05941,0.08584,75.01,0.07 2010-07-19,0.08584,0.09307,0.07723,0.0808,574,0.09

    1熱度

    3回答

    我是Esper開發新手,我遇到了一個小問題。 在SQL中,我有後續的查詢翻譯成艾斯波:由用戶從卡組選最大(時間) 我想要做的是,對於所有,我有活動,我想選擇每個用戶的最大(時間)並顯示它。 在Esper中,我將它翻譯爲以下方法:從用戶窗口組中選擇max(time)。但是,與SQL不同的是,每一個進入窗口的事件都會顯示出來,所以我最終得到了每個用戶的所有時間值,而不是最高值:/它不是通過「group