java矩阵乘法的mapreduce程序实现
map函数:对于矩阵M中的每个元素m(ij),产生一系列的key-value对<(i,k),(M,j,m(ij))>
其中k=1,2.....知道矩阵N的总列数;对于矩阵N中的每个元素n(jk),产生一系列的key-value对<(i,k),(N,j,n(jk)>,其中i=1,2.......直到i=1,2.......直到矩阵M的总列数。
map
packagecom.cb.matrix;
importstaticorg.mockito.Matchers.intThat;
importjava.io.IOException;
importorg.apache.hadoop.conf.Configuration;
importorg.apache.hadoop.io.Text;
importorg.apache.hadoop.mapred.FileSplit;
importorg.apache.hadoop.mapreduce.Mapper;
importcom.sun.org.apache.bcel.internal.generic.NEW;
publicclassMatrixMapperextendsMapper