java - マップタスクごとに入力ファイルを生成します

Question

私はHadoopを初めて使用しますが、次の問題があります。マッパーの数を制御したいのですが、私が見つけた最も簡単な方法は、pi推定器の例のように、hadoopをだまして各マップタスクの入力ファイルを生成することです。だから私は次のコードを使用しました：

    for(int i=0; i < nMaps; ++i) {
    final Path file = new Path(inDir, "part"+i);
    fs.create(file);
    fs.close();
    }

コンパイル時に、fs.create行にエラーがあります。誰かが何が間違っているのか、そしてそれをどのように解決できるのか知っていますか？ありがとう

score 0 · Accepted Answer

andIOExceptionからスローされる可能性のあるをキャッチ (または再スロー) する必要があります。createclose

1 に答える 1