scala - Flinkで1時間のリプレイストリームバッファを構築するには?

Question

過去 1 時間のイベントのバッファを動的に保持したいと考えています。そのバッファーは、過去 1 時間のデータに対してクエリを実行できるように、再生機能を提供する必要があります。Flink 内に既に実装されているものはありますか? それとも、自分で構築する必要がありますか?

Window API を使用しようとしましたが、Flink は順方向にシフトする固定幅の時間ウィンドウを提供しないようです。