0

我正在运行一个简单的 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
4

0 回答 0