文档首页 > > 开发指南> MapReduce应用开发> 开发规范> 建议

建议

分享
更新时间: 2019/04/30 GMT+08:00

全局使用的配置项,在mapred-site.xml中指定

如下给出接口所对应的mapred-site.xml中的配置项:

setMapperClass(Class <extends Mapper> cls) ->“mapreduce.job.map.class”

setReducerClass(Class<extends Reducer> cls) ->“mapreduce.job.reduce.class”

setCombinerClass(Class<extends Reducer> cls) ->“mapreduce.job.combine.class”

setInputFormatClass(Class<extends InputFormat> cls) ->“mapreduce.job.inputformat.class”

setJar(String jar) ->“mapreduce.job.jar”

setOutputFormat(Class< extends OutputFormat> theClass) ->“mapred.output.format.class”

setOutputKeyClass(Class<> theClass) ->“mapreduce.job.output.key.class”

setOutputValueClass(Class<> theClass) ->“mapreduce.job.output.value.class”

setPartitionerClass(Class<extends Partitioner> theClass) ->“mapred.partitioner.class”

setMapOutputCompressorClass(Class<extends CompressionCodec> codecClass)

->“mapreduce.map.output.compress”&“mapreduce.map.output.compress.codec”

setJobPriority(JobPriority prio) ->“mapreduce.job.priority”

setQueueName(String queueName) ->“mapreduce.job.queuename”

setNumMapTasks(int n) ->“mapreduce.job.maps”

setNumReduceTasks(int n) ->“mapreduce.job.reduces”

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区