Hadoop 排序
1、源代码(IMF)
package com.dtspark.hadoop.hellomapreduce;
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
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;
import org.apache.hadoop.util.GenericOptionsParser;
public class SortData {
/**
* 使用Mapper将输入文件中的数据作为Mapp输出的key直接输出
*/
public static class ForSortDataMapper
extends Mapper {
private LongWritable data = new LongWritable(1);
private LongWrita
