2014-04-29 41 views
1

我正在嘗試從基於匹配屬性(用戶)的時間窗口批量處理一堆事件。舉例來說,以下事件在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) 

回答