嗨,我是 Disco 的新手,并将现有代码集成到其中。Disco 是否能够将 map/reduce 函数作为类中的函数而不是全局函数来调用?下面的代码可能解释得更清楚。
class Segmenter(object):
def map_fun(line, params):
....
def reduce_fun(iter, params):
....
def disco_mp(self):
job = Job().run(input=["raw://word_to_segment_......"],
map=map_fun,
reduce=reduce_fun)
...
执行的结果是
NameError: global name 'map_fun' is not defined
但是,如果我将 map_fun、reduce_fun 更改为全局函数,它会按预期工作。但是我仍然必须找到一种方法让它作为类函数工作,有什么办法吗?
谢谢,
钱德勒