如何使用新API在hadoop中设置队列名称

Question

我看到在旧API org.apache.hadoop.mapred.JobConf类中有setQueueName用于设置队列名称的hadoop.任何人都可以指向我API使用新的类org.apache.hadoop.conf或org.apache.hadoop.mapreduce包中的等价物吗？

Answer 1

使用org.apache.hadoop.mapreduce.Jobclass设置配置,如下所示

job.getConfiguration().set("mapreduce.job.queuename", queueName);