武漢理工云計算重點(文件)
【正文】 rt 。 private Text word = new Text()。 } } } public static class IntSumCombiner extends ReducerText,IntWritable,Text,IntWritable { private IntWritable result = new IntWritable()。 (key, result)。 public void setup(Context text) throws IOException,InterruptedException { len = ().getInt(N,3)。 if( len) (key,result)。 } } } public void cleanup() { //收尾工作 排序并輸出TOP N Text[] keys = new Text[3]。 for(Iterator k:()) { keys[i] = (Text)()。ilen1。 keys[i] = keys[i+1]。ilen。//TOP N 定義 String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs()。 ()。 ()。 ((true) ? 0 : 1)。 // 向量值 public void map(Object key, Text value, Context context) hrows IOException, InterruptedException { StringTokenizer itr = new StringTokenizer(())。 IntWritable one = new IntWritable(result)。 } } public static class IntSumReducer extends ReducerText, IntWritable, Text, IntWritable { private IntWritable result = new IntWritable()。 (key, result)。 ()。 ()。 }}3. 程序中的類（1）matrix類用于存儲矩陣（2）IntPair類實現WritableComparable接口用于存儲整數對（3）matrixInputSplit類繼承了InputSplit接口，每個matrixInputSplit包括b個key,value對，用來生成一個積矩陣元素。其輸入為key1,list(value2)對，輸出為key1,value3對，key1不變，value3為IntWritable類型，值為key1值相同的所有value2的和。在main函數中，需要設置一系列的類，詳細內容參考源碼（7）MultipleOutputFormat類用于向文件輸出結果（8）LineRecordWriter類被MultipleOutputFormat中的方法調用，向文件輸出一個結果key,value對 4. 程序的運行過程（1）程序從文件中讀出數據到內存，生成matrix實例，通過組合左矩陣的行與右矩陣的列生成ac個matrixInputSplit（2）一個Mapper任務對一個matrixInputSplit中的每個key1,value1對調用一次Map方法對value1中的兩個整數相乘。 (job, new Path(output))。 ()。 Job job = new Job(conf, word count11)。 for (IntWritable val : values) { sum += ()。 j ++。 // 向量序號 (i + )。 // 矩陣行序號 private static int i = 0。 (job, new Path(otherArgs[0]))。 ()。 (2)。 } } } public static void main(String[] args) throws Exception { Configuration conf = new Configuration()。 keys[i+1] = tempt。 Text tempt = keys[i]。 i++。 int i = 0。 if(() ()) { (())。 for (IntWritable val : values) { sum += ()。 int len。 for (IntWritable val : values) { sum += ()。 while (()) { (())。import 。import 。import 。
教學教案相關推薦
鄂ICP備17016276號-1