如何使用mapreduce减去两个又高又瘦的矩阵?

a8jjtwal  于 2021-05-30  发布在  Hadoop
关注(0)|答案(0)|浏览(189)

我想用mapreduce减去两个又高又瘦的矩阵。一个矩阵存储在一个文件中,另一个矩阵存储在另一个文件中。如何应用mapreduce的概念,然后给hadoop同时输入两个文件的命令?(目前我正在用python中的dumbo来实现hadoop)
有人能提出主意或消息来源吗?

!['''x=0,y=0,z=0,a=0'''
x=0
y=0
z=0
a=0
def mapper1(key1,value1):
    x=key1
    y=value1
    yield x,y
'''yield key1,value1'''
def mapper(key,value):
    z=key
    a=value
    yield z,a
'''yield key,value'''
def reducer(x,y,z,a):
    if x==z:
       res=math.abs(y-a)
       yield x,res
if __name__ == "__main__":
    import numpy as np
    import math
    import dumbo
    dumbo.run(mapper1,mapper,reducer)
'''e''']

我收到一个错误:[1]:http://i.stack.imgur.com/qfzmy.png

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题