分布式文件系统-mapreduce-排序

很简单的，面向新手的一个MapReduce实例，对数据进行排序，对大数据理解很有帮助。

package cn.itcast.hadoop.mr.sort;

import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;

import org.apache.hadoop.io.WritableComparable;

public class InfoBean implements WritableComparable{

	private String account;
	
	private double income;
	
	private double expenses;
	
	private double surplus;
	
	public void set（String account double income double expenses）{
		this.account = account;
		this.income = income;
		this.expenses = expenses;
		this.surplus = income - expenses;
	}
	
	@Override
	public String toString（） {
		return this.income + “\t“ + this.expenses + “\t“ + this.surplus;
	}

	/**
	 * serialize
	 */
	public void write（DataOutput out） throws IOException {
		out.writeUTF（account）;
		out.writeDouble（income）;
		out.writeDouble（expenses）;
		out.writeDouble（surplus）;
	}

	/**
	 * deserialize
	 */
	public void readFields（DataInput in） throws IOException {
		this.account = in.readUTF（）;
		this.income = in.readDouble（）;
		this.expenses = in.readDouble（）;
		this.surplus = in.readDouble（）;
	}
	

	public int compareTo（InfoBean o） {
		if（this.income == o.getIncome（））{
			return this.expenses > o.getExpenses（） ? 1 : -1; 
		} else {
			return this.income > o.getIncome（） ? -1 : 1;
		}
	}

	public String getAccount（） {
		return account;
	}

	public void setAccount（String account） {
		this.account = account;
	}

	public double getIncome（） {
		return income;
	}

	public void setIncome（double income） {
		this.income = income;
	}

	public double getExpenses（） {
		return expenses;
	}

	public void setExpenses（double expenses） {
		this.expenses = expenses;
	}

	public double getSurplus（） {
		return surplus;
	}

	public void setSurplus（double surplus） {
		this.surplus = surplus;
	}

	
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        1742  2014-06-03 16:03  sort\InfoBean.java
     文件        2114  2014-06-03 15:58  sort\SortStep.java
     文件        2184  2014-06-03 15:21  sort\SumStep.java
     目录           0  2018-09-11 20:37  sort\