Pub/Sub から Dataflow に株価をストリーミングし、5 秒ごとに過去 30 秒間の移動平均を計算する必要があります。ウィンドウとトリガーはどのように構成すべきですか？

株価の移動平均を計算し、5秒ごとに更新する必要があるため、スライディングウィンドウが適切です。移動平均は過去30秒間のデータに基づいているため、ウィンドウの期間は30秒です。5秒ごとに新しい計算結果が必要なため、スライディングウィンドウの周期（スライド間隔）は5秒に設定します。AfterWatermark.pastEndOfWindow()トリガーは、ウォーターマークがウィンドウの終了時刻を超えたときに結果を出力するため、完全なデータが処理された後に正確な移動平均が計算されます。他のオプションは、固定ウィンドウや不適切なトリガー設定により、要件を満たしません。例えば、固定ウィンドウでは5秒ごとの更新ができません。