這是我的工作人員的外表。如何在觸發這項工作時設定低優先級？

public int run(String[] args) throws Exception {

this.initJob();

Path outputPath = new Path(args[2]);

FileInputFormat.setInputPaths(job, args[0]);

FileOutputFormat.setOutputPath(job, outputPath);

job.getConfiguration().set("FREQUENCY", args[3]);

job.getConfiguration().set("TIMEZONE", args[4]);

boolean rc = job.waitForCompletion(true);

if (rc) {

return 0;

}

return 1;

}

public void initJob() throws IOException {

job = new Job(getConf(), "Stats Data Cruncher");

job.setMapOutputKeyClass(Text.class);

job.setMapOutputValueClass(Text.class);

job.setOutputKeyClass(Text.class);

job.setOutputValueClass(NullWritable.class);

Job.setInputFormatClass(LzoTextInputFormat.class);

job.setJarByClass(JobRunner.class);

job.setMapperClass(StatsMapper.class);

job.setCombinerClass(StatsCombiner.class);

job.setReducerClass(StatsReducer.class);

}這條線是否有效設置低優先級？

job.getConfiguration().set("PRIORITY", "LOW");

總結

以上是生活随笔為你收集整理的作业优先调度java代码_如何在触发它时在java代码中为hadoop作业设置优先级？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。