apacheの中心時刻ウィンドウflink

Question

興味のあるイベントが中心のウィンドウを収集することは可能ですか？

は、イベントのストリームを想像してみて：特に

....e...........e...E........e...... 

を私はトリガイベントEとその周辺に興味があります（+ - 数分）：

でこのロジックを実装する

....e..........|e...E....|....e...... 

Answer 1

Flinkのウィンドウ演算子（カスタムTriggerとEvictorの実装を含む）は可能ではあるが、私の意見ではかなり難しい。

もっと良いアプローチはProcessFunctionだと思います。 ProcessFunctionは、コールバック関数を呼び出すタイマー（処理時間またはイベント時間）を登録できます。指定されたユースケースの場合、ProcessFunctionは管理状態のすべてのレコードを収集します。トリガー・イベントが受信されると、トリガー・イベントの周りのウィンドウ境界が切れるまで、より多くのイベントが到着するのを待つためのタイマーが登録されます。さらに、ProcessFunctionは、トリガーイベントに関連付けられるには早すぎるすべての要素を定期的に削除する必要があります。これは、タイマーを登録することによっても行うことができます。