hadoop上的矩阵乘法

Question

我正在寻找在 hadoop java 上进行矩阵乘法的最佳且简单的方法。同时，我查看了此链接http://www.norstad.org/matrix-multiply/index.html，但我很难理解它。

总体而言：我有两个文件 matrixA(m x n) 和 matrixB(n x m)。我想要矩阵C(m x m) 通过将A 和B 相乘。我将上面的两个文件传递给mapreduce 程序。

请帮帮我..

Answer 1

您能否将矩阵两个文件重新处理为：

 System.out.println( column + " , " + row + "\t" + value );

我认为您可以通过输出来映射两者：

context.write( new Text( column + " , " + row ), new IntWritable( value ) );

然后使用迭代器减少并乘以值。

for( int val: value ) {
    int result *= val;
}

context.write( key, new IntWritable( result ));