esper

0熱度

1回答

我要處理使用艾斯波以下JSON消息： { "firstname":"John", "lastname":"Do", "address":[{"street":"Maplestreet","number":100,"city":"New York"}] } 什麼是聲明的事件類型模式的正確方法是什麼？有人可以幫我構建正確的EPL：create schema();聲明

0熱度

1回答

EPStatmentObject模型不工作？

我試圖通過編譯使用compileEPL（）方法來修改epl，並添加更多的例如where子句，但我很難得到它的工作。比方說這是我的EPL： select * from event where A = 1 ，我想使用AND 再添加一個WHERE條件和我編譯使用compileEPL（）英超 model.getWhereClause().getChildren().add(Expressions.a

0熱度

1回答

Esper。無法在偵聽器中接收刪除事件

在Esper中使用時間窗口時，窗口中的舊事件或已刪除事件將作爲輸出發送到附加到該語句的UpdateListener。這是根據該文件應該發生的事情。但是當我執行下面的代碼時，即使一個新的滑動窗口啓動，它在oldEvents中也沒有任何事件。它甚至發生在長度窗口。 EPStatement statement1 = epAdmin.createEPL("select current_timestamp,

0熱度

1回答

艾斯波訪問陣列事件propertie

我想用艾斯波處理以下JSON消息： { "firstname":"John", "lastname":"Do", "address":[{"street":"Maplestreet","number":100,"city":"New York"}] } 當架構的樣子： create schema Address (street string, number in

0熱度

1回答

調用的方法只能運行一次

我有一個在查詢中調用的方法。然而，它只運行一次，但假設我發送了10個事件，監聽器輸出兩個空事件。 select method() from Event.win:length_batch(5) 來自監聽器的結果：這是正確的，因爲方法dosent返回任何內容，但該方法只在觸發兩次時觸發一次。 {method()=null} {method()=null} 有誰知道爲什麼嗎？我想在每次窗口填滿

1熱度

1回答

Invoke方法，一旦所有包含事件

我如何可以調用的方法類似 select udf(a,b) from Event.win:length_batch(5) 中並重新打印尺寸5的窗口。假設我發送了以下事件： runtime.sendEvent(new Event(1,2)); runtime.sendEvent(new Event(3,4)); runtime.sendEvent(new Event(4,2)); runti

0熱度

1回答

複雜事件處理流處理

我想了解Esper如何與Storm合作。我看看Esper的源代碼，因爲我想知道Esper（表，數組等）存儲的數據的位置。例如當esper接收到一串元組並且聲明瞭一個事件類型時，這個數據是如何被Esper存儲的（源代碼）;當執行一個查詢時數據結果如何存儲等等？我想在Esper的源代碼中找到所有這些發生的地方code.Any幫助是最受歡迎的。

0熱度

1回答

艾斯波輸出解釋

考慮下列事件流和上下文的定義： create schema EventCreated( source String, type String, time String, value Integer ); create context Trip context bySource partition by source from Eve

0熱度

1回答

如何在espertech中獲取觸發事件的列表CEP

我已經在我的項目中實現了espertech CEP，並且一切都很好，但是我想顯示所有觸發事件的列表。 espertech是否允許這樣做？

0熱度

1回答

帶參數的Esper計數

我想知道是否可以使用「count」函數或等同函數但指定了參數，只計算特定結果。所以我想這樣做： select ... "nbAccel", count(type='c8y_HarshBehavior' and behaviorType = "ACCELERATION") "nbBraking", count(type='c8y_HarshBehavior' and