esper

0熱度

1回答

我想使用select語句，其中一個字段的值取決於2個窗口的值。最後還使用where語句過濾掉1 wiondow中的事件。例如。 Select coalesce(B.field1,0) + A.field1 as field1, coalesce(B.field2,0) + A.field2 as field2 from Window1 A unidirectional, Window2

0熱度

1回答

Twitter4j和Esper：在主java.lang.NoClassDefFoundError拋出錯誤

我正在按照教程http://www.javacodegeeks.com/2012/03/twitter4j-and-esper-tracking-user.html。但是，當我試圖編譯它給了我follwoing錯誤的項目： Exception in thread "main" java.lang.NoClassDefFoundError: org/antlr/runtime/RecognizerS

0熱度

1回答

您應該使用equals方法還是比較Esper中EventType的事件類型ID？

我想檢查兩個Esper的EventType對象是否相等。同樣我的意思是它們是具有相同屬性的相同事件類型。我想知道做什麼是最好的方法。是可以安全使用equals方法，像這樣： eventType.equals(otherEventType) 由於EventType是一個接口，我不能肯定所有的實現類將覆蓋equals方法。正因爲如此，我認爲上面的代碼不是一個好主意。，我能想到的另一種選擇是比較

0熱度

1回答

Esper在jboss上部署爲7.X，事件類型或類名未找到

我開發了一個java ee項目，將其作爲7服務器部署在jboss上。情況是 A java ee project in which ejb module contains execution classes. some of the pojo events are defined in another plain java project lets say p1 and p1 is r

1熱度

1回答

計算布爾結果顯示一對事件是否匹配或不艾斯波

我想創建一個EPL聲明，將顯示訂單是否成功與否。聲明應與付款購買，根據購買的ID。結果應該包含購買和一個布爾值，表明購買是否與付款匹配的ID。我有下面的語句時，成功匹配時返回true。不過，我也想在購買退出30秒的時間窗口沒有被匹配到支付返回一個錯誤。 SELECT Purchase.purchaseId AS purchaseId, true AS successful FROM Purc

1熱度

1回答

如何在不使用ESPERHA的情況下實現ESPER（使用WSO2）實現持久性以防故障切換？

我用esper作爲後端使用WSO2 CEP-ServerEND-Runtime.WSO2使用cassandra爲siddhi（backEnd-runtime）提供了持久性。我需要用ESPER-CEP引擎實現持久性。任何想法將不勝感激。

1熱度

1回答

esper如何查找存在於streamA中的ID但不存在於streamB中的ID

問題很簡單：使用Esper引擎僅提取2個不同流中不存在的記錄。 ID存在於streamA中，但不在streamB中退出。在SQL它應該是這樣的： SELECT * FROM tableA WHERE NOT EXISTS (SELECT * FROM tableB WHERE tableA.Id = tableB.Id) 我已經試過了艾斯波風格，但它不

1熱度

1回答

ESPER使用csv適配器與POJO

我需要esper使用csv文件作爲輸入與csv適配器一些幫助。我需要使用POJO類和超過1個csv文件。如果有一個例子包含上面的監聽器，我會很感激。感謝

1熱度

1回答

Esper - 是否有任何開源的基於RDBMS的Event Store可用？

我們爲我們的BI解決方案使用Esper CEP引擎（基礎版）。我也想堅持事件到甲骨文。 Esper有一個單獨的企業產品EsperHA，它提供這種功能。 Esper HA是全面HA產品。我們只需要事件持久性，以便其他應用程序可以直接或通過Esper使用該數據。是否有任何可用於EsperHA類型功能的基於Java的開源實現？我找不到一個。基本上，我正在尋找基於RDBMS的時間序列數據庫，它可以爲Esp

0熱度

1回答

在艾斯波使用數組CEP

下面是我們艾斯波EPL聲明： insert rstream into SelectedFieldsStream select rstream feedId as feedId , data.inputEvents.inputEventCount as inputCounts , data.inputEvents.inputEvent[1].name as