esper

0熱度

2回答

我正在使用Esper &我需要按他們的時間戳過濾事件。事件來自外部來源。挑戰在於截止時刻與事件時間戳不同，例如，截止時刻爲3:30 CET（例如布拉格時間），而事件的時間戳字段爲UTC。由於需要在查詢中修改截止時刻，所以在時區轉換爲夏令時時會出現問題。例如。在這種情況下，如果截止時刻爲3:30 CET，冬季時間爲UTC時間2:30，DST時間爲UTC時間1:30。這意味着我必須在時間移入和移出

0熱度

1回答

esper線程池與上下文和用戶調度訂單

如果Esper應用程序與上下文一起工作，您可以使用線程池入站嗎？啓用它我有一些錯誤與唯一鍵。另一方面，如果用戶調度順序很重要，是否可以使用線程池出站？謝謝，

0熱度

1回答

艾斯波 - 在模式過濾器表達式中使用用戶定義的函數

我不明白爲什麼我不能做到這一點： select * from pattern [every A = EventA -> EventB(myFunction(A.property))] 從艾斯波文檔：「所有的表達式可以在過濾器中使用，包括靜態方法調用返回一個布爾值「。如果我不嘗試從第一個匹配事件（EventA）引用屬性，而是隻嘗試將EventB中的屬性傳遞給myFunction，則它工作正常。

0熱度

1回答

關於使用超能力魔「組的」 +「和」

一個謎我創建了一個英超這樣的： `String epl = "select objId,sum(c1) from PmData.win:time_batch(3 sec) group by objId";` 這是非常簡單的：出口總和（C1）在滑動窗口每3秒造成。但是當我運行測試時，結果不是我預期的那樣，它看起來是錯誤的：它導出不存在於滑動窗口中的objId。下面是結果打印：選擇OBJID

0熱度

1回答

定義基於集合中元素屬性觸發事件的EPL語句

我有指向元素集合的對象。我想要做的是定義一個EPL語句，爲每個包含集合中至少有一個元素的對象觸發一個事件，以滿足某些條件。類似這樣的： insert into SomeComplexEvent select SomeObjectID from SomeObject as obj where exists elem in obj.elemsCollection where

0熱度

1回答

如何獲取最新事件的元素（應過濾空值）該組按某些鍵

我是一個新的使用esper，我有一個問題，不知道如何構建EPL。我想要得到最新的"index"'s element:「e1」（不包括空值）和sum（e2），並且在每個事件中e1可能存在或不存在，我想要得到最新的"index"'s element:「e1」（不包括空值）和sum（e2）按「鍵」分組。我寫了一個EPL這樣的： select key, sum(e2), maxby(index).e1

0熱度

1回答

Esper規則語言：只有在條件滿足特定時間段後才執行規則

我想編寫一個規則，當心率超過160分鐘時觸發5分鐘。我想出了這個規則如下： EPAdministrator cepRule3 = cep.getEPAdministrator(); EPStatement cepStatementRule3 = cepRule3.createEPL("select * from " + "HeartRate.win:time(5 min

0熱度

1回答

艾斯波規則語言：上下文嵌套

我有以下兩類心率與字段： int heartrate; String heartratesTimestamp; String macAddress; 和步驟與字段： int steps; String stepsTimestamp; String macAddress; 我寫了火災規則時的步數最近1分鐘超過100次，心率超過160. EPStatement cepStatemen

0熱度

1回答

如何在esper中獲得舊事件？

我在Esper中做了一個基於長度窗口的程序。但是當窗口已滿時，以前的事件應該成爲一箇舊事件。當我試圖在updateListener中打印那個舊事件時，我每次都變空。 EPServiceProvider sp = EPServiceProviderManager.getDefaultProvider(); String qry = "select count(*) from com.biz

1熱度

1回答

OSGi框架內使用艾斯波

我想用戶艾斯波OSGi框架內，但我不知道內OSGi的類加載機制怎麼會允許我需要什麼來實現，甚至如何艾斯波可以在OSGi的，因爲它被使用。我使用艾斯波5.3並且在束檢查體現它不使用OSGi的Dynamic-Import頭。 Esper的核心是我所理解的是在POJO上運行的SQL查詢的EPStatements。我很難理解的是，Esper捆綁包如何不使用動態導入，並且不知道將來可能針對哪些POJO進