MR编程之Top3源代码

package com.top3;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;

public class TOP3 {
	//@author YQ
	public static class TopNMap extends Mapperject Text IntWritable NullWritable>{
		private static IntWritable data = new IntWritable（）;
		@Override
        protected void map（object key Text valueContext context）
                throws IOException InterruptedException {
		 //把字符串转为数值
          data.set（Integer.parseInt（value.toString（）.trim（）））;
          context.write（data NullWritable.get（））;
         // System.out.println（data）;
        }
    }
	
	public static class TopNReducer extends Reducer{
		private ArrayList keyList = new  ArrayList（）;
		private IntWritable num = new IntWritable（）;
		@Override
	     public void reduce（IntWritable key Iterable values Context context） throws IOException InterruptedException {
			 //int kk = key.get（）;
			 keyList.add（key.get（））;
			 //System.out.println（kk）;
		 }
		
		@Override
		protected void cleanup（Context context） throws IOException InterruptedException{
			Collections.sort（keyList）;//从