} // 记录开始时间 DateFormat HH:mm:ss"); formatter = new SimpleDateFormat("yyyy-MM-dd Date start = new Date(); // 运行任务 int res = ToolRunner.run(new Configuration(), new Apriori(), args); // 输出任务耗时 Date end = new Date(); float time = (float) ((end.getTime() - start.getTime()) / 60000.0); System.out.println("任务开始：" + formatter.format(start)); System.out.println("任务结束：" + formatter.format(end)); System.out.println("任务耗时：" + String.valueOf(time) + " 分钟"); System.exit(res); } @Override public int run(String[] args) throws Exception { // TODO Auto-generated method stub Configuration conf = getConf(); Job job = new Job(conf, "Apriori"); // 任务名 job.setJarByClass(Apriori.class); // 指定 Class job.setJobName("Apriori map reduce"); FileInputFormat.addInputPath(job, new Path(args[0])); Path path =new Path(args[1]) ; FileSystem.get(conf).delete(path, true); FileOutputFormat.setOutputPath(job, path); job.setMapperClass(MAP.class); job.setReducerClass(REDUCE.class); job.setOutputKeyClass(Text.class); job.setOutputValueClass(IntWritable.class); job.setNumReduceTasks(1); job.waitForCompletion(true); // 输出任务完成情况 System.out.println("任务名称：" + job.getJobName()); System.out.println("任务成功：" + (job.isSuccessful() ? "是" : "否")); System.out.println("输入行数：" + job.getCounters() System.out.println("输出行数：" + job.getCounters() .findCounter("org.apache.hadoop.mapred.Task$Counter", "MAP_INPUT_RECORDS").getValue()); .findCounter("org.apache.hadoop.mapred.Task$Counter", "REDUCE_OUTPUT_RECORDS").getValue()); 

System.out.println("跳过的行：" return job.isSuccessful() ? 0 : 1; + job.getCounters().findCounter(Counter.LINESKIP).getValue()); } } 使用手册： 输入输出路径：hdfs://master:9000/apriori/apriori.txt hdfs://master:9000/apriori/out