ユーザーごとにイベントをグループ化し、バッチで (ユーザーごとに) 返そうとしています。たとえば、3 人のユーザーがそれぞれ 5 つのイベントを送信した場合、5 つのイベントの 3 つのバッチを esper から出力したいと考えています。
次の EPL を使用して、3 つのデータ ウィンドウが作成され、各ウィンドウに 5 つのイベントがあることを検証できます。
select * from EVT.std:groupwin(User).win:time_batch(2).std:size()
ただし、 std:size() を削除すると、15 個のイベントすべてが 1 つのバッチで返されます。私が理解しているように、これは std:groupwin グループ化ウィンドウ ビューが std:merge ビューによって評価される方法によるものです。
すべてをマージせずに、各データ ウィンドウからバッチ処理されたイベントを出力するにはどうすればよいですか?