我想用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
暂无答案!
目前还没有任何答案,快来回答吧!