再起動後の処理再開

Global Retail Analytics のストリーミングパイプラインは、Unity Catalog ボリュームから新しい CSV ファイルを取得し、Delta Lake に書き込む処理を行っています。週末に障害が発生してクラスターが停止し、月曜日の朝に再起動しました。週末の間に新しいファイルが3つ到着していました。ストリームはその3ファイルのみを処理し、前の週のファイルは再読み込みされませんでした。

ストリームが処理済みのファイルをスキップし、中断した場所から正確に再開できるのはなぜでしょうか？