2015-07-12 56 views
0

我需要有關CEP引擎艾斯波一些幫助: 我寫了下面的語句:艾斯波 - 規則觸發兩次

SELECT clientID FROM MovementEvent.win:time_batch(5 sec) GROUP BY clientID 

然後我把一個MovementEvent進入發動機。 5秒後,用戶被觸發 - 確定。但是再過5秒後,它又被觸發了 - 爲什麼?

無論我有多少事件發送到引擎,用戶總是被觸發兩次 - 5到10秒

我希望你能幫助我了!

SELECT clientID FROM MovementEvent.std:groupwin(clientID).win:time_batch(5 sec); 

在一般情況下,使用GROUP BY而不適用於您選擇將幾乎總是抓住你的屬性聚合函數措手不及:;

謝謝)

回答

0

組,通過使這個聚集和埃斯佩爾提供輸出時,有即使您不選擇聚合,也會改變密鑰的聚合。 你可以做到這一點

select window(*).distinctOf(v=>client) from MovementEvent.win:time_batch(5 sec)