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
