我正在使用 JobConf 并且我正在使用这样的多线程映射器:
import org.apache.hadoop.mapred.lib.MultithreadedMapRunner;
conf.setMapRunnerClass(MultithreadedMapRunner.class);
现在如何设置线程数?
提前致谢..
它在该类的 Javadoc 中,但是有一个关于 javadoc 没有正确生成该类的JIRA 错误。无论如何,您正在寻找的财产是:
mapred.map.multithreadedrunner.threads