nesper

    0熱度

    1回答

    是否可以嵌套這樣的兩個crontab上下文? create context Nest context A start (0, *, *, *, 1) end (0, *, *, *, 6), context B start (0, 8, *, *, *) end (0, 22, *, *, *) 第一個上下文是否決定第二個上下文? 如果是這樣,我認爲,A應該是自決定日子以來的第一個,並且第

    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

    1熱度

    1回答

    我如何可以調用的方法類似 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回答

    我想要在下面兩個上下文中指定的時間之間選擇相同的語句。但是我沒有輸出。當B處於活動狀態並且C在單個語句中使用嵌套上下文處於活動狀態時,如何獲得輸出? create context A context B start (0, 12, *, *, *) end (0, 18, *, *, *), context C start (0, 20, *, *, *) end (0, 23

    -1熱度

    1回答

    我使用Nesper作爲CEP引擎來處理我的應用程序中的事件。 我想下面的EPL聲明型號: 事件的Value場的平均值在有限窗口時間。 如果這些平均值中的任何一個匹配了1期望值,則會生成一個事件。 我此建模爲: SELECT ( (AVG(ParameterEvent1.Value) = 1) OR (AVG(ParameterEvent2.Value) = 1) ... (AVG(Param

    0熱度

    1回答

    是否有可能創建一個主鍵和一個設置爲輔助列的表,就像一個哈希表的值列表中的表? 是這樣的: create table T (id int primary key, list HashSet) 在名單將舉行有關所發生過的窗口大小的主鍵的所有屬性。 編輯: 這是輸出我得到。我要的是保持獨特OCCURENCES的數量在ID 1,2和3 到達如果Occurence 2在ID 1到達3倍我還是隻想要1獨樹

    0熱度

    1回答

    我想用NEsper測量具有唯一標識的汽車的時間。我的問題是,道路上有幾輛車。這條路有預定義的步驟。我想要開始停止每一輛獨一無二的汽車的時間,直到這款汽車獲得最後一步。 select ice.* from pattern[ice = IncomingCarEvent -> every timer:interval(1 sec) and not LastStepEvent] 問題是,我不知道如何將

    0熱度

    1回答

    我有窗口長度的問題。 我的條件:如果事件長度內發生 1輸出將觸發3 2輸出駁回如果事件長度後發生3 實施例: 事件序列: 1: 2 :乙 3:C 4:d 5:電子 6: 7:C 8:d 9:電子 10:F 11:乙 事件規則: Z = A - >乙 期望輸出位:Z將在索引號2發生自贏:長度(3) 我的問題:該輸出端Z也觸發的索引號11 eventhought超過WIN:長度(3) 我簡單的代碼:

    0熱度

    1回答

    Esper是否可以通過輸入管理時間戳。我使用的文件是這樣的: 143 Sat Sep 12 14:43:05 CEST 2009 149 Sat Sep 12 14:43:06 CEST 2009 149 Sat Sep 12 14:43:09 CEST 2009 143 Sat Sep 12 14:43:10 CEST 2009 149 Sat Sep 12 14:43:12 CEST

    0熱度

    1回答

    我有esper processer配置爲在kafka中偵聽郵件。 通常select * from events.win:time(2 min)將觸發最近2分鐘內的所有事件 現在,如果最後2分鐘沒有卡夫卡消息,我想觸發通知。 我應該怎麼處理它,當我喜歡寫東西 select * from events(Ip='1.1.1.1').win:time(2 min) 這不會有匹配的郵件/事件和超能力者不觸發