通販サイトのデータ基盤チームが、Dataflow から BigQuery の Storage Write API で注文データを書き込んでいる。スキーマに合わない行があると書き込みが失敗するが、その行がどこへ消えたのか追えていない。Dataflow から BigQuery へ書き込む際に失敗した行を回収したいと考えている。使うべき仕組みはどれか。