定期的にウィンドウをトリガーする方法は？

Question

私は最後のN時間のデータをM分ごとに処理したいと思います。データはpubsubを介してさまざまな遅延が発生しますが、時間のずれやデータの遅れなどによるウィンドウのトリガを遅延させたくありません。つまり、トリガ時に利用可能なデータを処理したいだけで、壁の時間に基づいてトリガしたいとします（ただし、各ウィンドウにはデータイベント時間に基づいて[トリガされた時間 - M時間、トリガされた時間]の間のデータが含まれている必要があります）。

SlidingWindowsを使用しようとしていますが、トリガーはイベントの時間に基づいており、データの遅延のために遅延しているようです。

これを行うにはどのような方法が最適ですか？

おかげで、

Answer 1

あなたはFixedWindowsでAfterProcessingTime.pastFirstElementInPane().plusDelayOf(...)トリガーを使用する必要があります。これはあなたが記述しているのとまったく同じように動作します。