ストリーミング推論において、遅れて到着したデータ(Late Data)を適切に処理または破棄するために設定する機能はどれか。

ウォーターマークを設定することで、イベント時間に基づいてどこまで古いデータを受け入れるかの閾値を定義し、状態管理を行う。