我正在运行一个简单的 pydoop 程序来计算“alice.txt”中的单词。然而得到一个奇怪的错误。我不确定是否缺少某些模块或代码错误。
Pydoop 代码:
#!/usr/local/bin/python
import pydoop
def mapper(_,text,writer):
for word in text.split():
writer.emit(word,"1")
def reducer(word,icounts,writer):
writer.emit(word,sum(map(int,icounts)))
def combiner(word,icounts,writer):
writer.count('combiner calls', 1)
reducer(word,icounts,writer)
挂载和运行pydoop代码的步骤:
pydoop script -c combiner wc.py alice.txt a.txt
错误 :
ImportError: No module named _hdfs_2_0_0_cdh_4_3_0