2

Spark ジョブで BigQueryInputFormat を使用して、Bigquery から RDD に直接データをロードしています。これに関するドキュメントには、次のコマンドを使用して一時ファイルをクリーンアップする必要があると記載されています。

BigQueryInputFormat.cleanupJob(ジョブ)

ただし、Spark ジョブから、「ジョブ」が Hadoop ジョブの場合、どうすればそれを行うことができますか?

ありがとう、ルーク

4

1 に答える 1