public int run(String[] args) throws Exception { Configuration conf = this.getConf(); Job job = Job.getInstance(conf, "traitement"); job.setJarByClass(TraitementDriver.class); job.setMapperClass(TraitementMapper.class); job.setReducerClass(TraitementReducer.class); FileInputFormat.addInputPath(job, new Path(args[0])); FileOutputFormat.setOutputPath(job, new Path(args[1])); boolean success = job.waitForCompletion(true); return success ? 0 : 1; }