Structured Streamingで、イベント時間(Event Time)に基づいて遅れて到着したデータを破棄するための機能はどれか。

Watermark(透かし)を定義することで、システムは「これ以上古いデータは到着しない(または処理しない)」という閾値を設け、ステートのクリーンアップと遅延データの破棄を行う。