我正在嘗試從基於匹配屬性(用戶)的時間窗口批量處理一堆事件。舉例來說,以下事件在1秒內通過esper:如何根據共享屬性在Esper中對事件進行批處理
用戶|文件
一個 | a1.sys
一個 | a2.inf
一個 | a3.sys
乙 | b1.sys
乙 | b2.sys
一個 | a4.sys
乙 | b3.inf
欲批次由用戶和輸出以下2組事件的事件:
輸出1
甲 | a1.sys
一個 | a2.inf
一個 | a3.sys
一個 | a4.sys
輸出2
乙 | b1.sys
乙 | b2.sys
乙 | b3.inf
關鍵是這些組需要輸出爲集合,而不是每個事件輸出一個。我需要模擬響應我會從下面的查詢(如事件,b和c返回集合)獲取類型:
SELECT * FROM pattern[every a -> b -> c]
我只是無法弄清楚如何塑造這樣的查詢。我已經嘗試了以下內容,但它並未將事件一起批處理。
select * from ActivityEvent().std:groupwin(User).win:time_batch(5)