資源簡介
很簡單的,面向新手的一個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\
- 上一篇:移遠MC20模塊調試MPU6050
- 下一篇:基于Labview的用戶登錄程序
評論
共有 條評論