91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

資源簡介

最近在研究hadoop與mapReduce，網上教程只有個wordcount程序示范，太簡單，故寫了個相對復雜點的涉及到多個文件之間同時運算的矩陣乘法的代碼用于實驗與測試，上傳供大家學習與參考。 調用方法： 執行：hadoop jar matrix.jar com.baosight.mapred.test.MatrixMulti left:/tmp/a right:/tmp/b output:/tmp/c leftprefix:000000_ rightprefix:000000_ >參數1：left:左矩陣路徑 >參數2：right:右矩陣路徑 >參數3：output:左矩陣乘右矩陣結果路徑 >參數4：leftprefix：左矩陣文件前綴 如/tmp/a/000000_0,000000_1,000000_2……的000000_ >參數5：rightprefix：右矩陣文件前綴 >左右矩陣按列存儲，每個文件只存放一列值，如2x2的單位矩陣， 000000_0存放1 0 000000_1存放 0 1

資源截圖

代碼片段和文件信息 

/**
?*?Copyright?2012?寶信軟件?解決方案事業部
?*?
?*?@author?樊后禮???f_houli@163.com????fanhouli@baosight.com
?*/
package?com.baosight.mapred.test;

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

import?org.apache.hadoop.io.LongWritable;
import?org.apache.hadoop.io.WritableComparable;

public?class?MapInputKey?implements?WritableComparable{
	
	public?int?leftColNum?=?0;
	public?int?rightColNum?=?0;
	
	public?MapInputKey（）{}
	@Override
	public?void?write（DataOutput?out）?throws?IOException?{
		out.writeInt（leftColNum）;
		out.writeInt（rightColNum）;
		
	}
	@Override
	public?void?readFields（DataInput?in）?throws?IOException?{
		leftColNum?=?in.readInt（）;
		rightColNum?=?in.readInt（）;
		
	}
	@Override
	public?int?compareTo（object?o）?{
		MapInputKey?other?=?（MapInputKey）?o;
		if?（this.leftColNum?==?other.leftColNum
				&&?this.rightColNum?==?other.rightColNum）?{
			return?0;
		}?else?{
			return?1;
		}
	}
	
	public?boolean?equals（object?o）?{
	????if?（!（o?instanceof?MapInputKey））
	??????return?false;
	????MapInputKey?other?=?（MapInputKey）o;
	????return?（this.leftColNum?==?other.leftColNum?&&?this.rightColNum?==?other.rightColNum）;
	??}
}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件????????1197??2012-06-27?01:19??src\com\baosight\mapred\test\MapInputKey.java
?????文件?????????787??2012-06-27?01:20??src\com\baosight\mapred\test\MapInputValue.java
?????文件????????2738??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixInputFormat.java
?????文件????????2769??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixInputRecordReader.java
?????文件????????1641??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixInputSplit.java
?????文件????????1347??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixMapper.java
?????文件????????2702??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixMulti.java
?????文件?????????947??2012-06-27?01:20??src\com\baosight\mapred\test\MatrixReducer.java
?????文件????????2932??2012-06-27?01:20??src\com\baosight\mapred\test\ReduceInputKey.java
?????文件?????????867??2012-06-27?01:20??src\com\baosight\mapred\test\ReduceOutputValue.java
?????目錄???????????0??2012-06-27?01:29??src\com\baosight\mapred\test\
?????目錄???????????0??2012-06-27?01:09??src\com\baosight\mapred\
?????目錄???????????0??2012-06-27?01:09??src\com\baosight\
?????目錄???????????0??2012-06-27?01:09??src\com\
?????目錄???????????0??2012-06-12?07:52??src\

評論

共有 條評論