编程实现按访问次数排序

        accessTimesSort.java

//    Mapper模块
     public static class MyMapper
        extends Mapper{
                 public void map(Object key, Text value, Context context) //map函数的编写要根据读取的文件内容和业务逻辑来写
                               throws IOException, InterruptedException {
                        String line = value.toString();
                        String array[] = line.split("t");//指定,为分隔符，组成数组
                        int keyOutput = Integer.parseInt(array[1]);//提取数组中的访问次数作为Key
                        String valueOutput = array[0]; //将日期作为value
                        context.write(new IntWritable(keyOutput), new  Text(valueOutput));
                 }
           }
    
//    Reducer模块
     public static class MyReducer
        extends Reducer {//注意与上面输出对应
                 public void reduce(IntWritable key, Iterable values, Context  context)  
                               throws IOException, InterruptedException {
                        for (Text value : values) {
                               context.write(value, key);                //进行键值位置互换
                        }
                 }
           }
//    Driver模块
     public static void main(String[] args) throws Exception {
         Configuration conf = new Configuration();
         
         Job job = Job.getInstance(conf, "AccessTimesSort");
         job.setJarByClass(accessTimesSort.class);
         job.setMapperClass(MyMapper.class);
         job.setReducerClass(MyReducer.class);
         job.setMapOutputKeyClass(IntWritable.class);
         job.setMapOutputValueClass(Text.class);
         job.setOutputKeyClass(Text.class);
         job.setOutputValueClass(IntWritable.class);
         for (int i = 0; i < args.length - 1; ++i) {
           FileInputFormat.addInputPath(job, new Path(args[i]));
         }
         FileOutputFormat.setOutputPath(job,
           new Path(args[args.length - 1]));
         System.exit(job.waitForCompletion(true) ? 0 : 1);
       } 

2.编译生成accessTimesSort.jar包文件 3.将accessTimesSort.jar包上传至Hadoop的/opt目录下。 4.以hadoop jar提交任务给集群：
    命令：
  hadoop jar accessTimesSort.jar /user2/optput01 /user2/root/optput02 5.在HDFS中/user2/root/output02/part-r-00000下即可查看结果