/ / Jak ustawić nazwę kolejki w hadoopie za pomocą nowego API - java, hadoop

Jak ustawić nazwę kolejki w hadoopie za pomocą nowego API - java, hadoop

Widzę to w starym API org.apache.hadoop.mapred.JobConf klasa miała setQueueName który został użyty do ustawienia nazwy kolejki w hadoop . Czy każdy może wskazać mi odpowiednik API używanie nowych klas w org.apache.hadoop.conf lub org.apache.hadoop.mapreduce pakiety?

Odpowiedzi:

6 dla odpowiedzi № 1

Posługiwać się org.apache.hadoop.mapreduce.Job klasa, aby ustawić konfigurację, jak pokazano poniżej

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