私は JobConf を使用しており、その中で次のようなマルチスレッドマッパーを使用しています:
import org.apache.hadoop.mapred.lib.MultithreadedMapRunner;
conf.setMapRunnerClass(MultithreadedMapRunner.class);
スレッド数を設定するにはどうすればよいですか?
前もって感謝します..
1 に答える
1
このクラスのJavadocにありますが、このクラスのjavadocが正しく生成されないというJIRAのバグがあります。とにかく、あなたが探しているプロパティは次のとおりです。
mapred.map.multithreadedrunner.threads
于 2012-04-30T10:32:22.093 に答える