这句话(yield "lines", 1)在mrjob的官方文档中是怎么工作的
how does this sentence(yield "lines", 1) work in mrjob's Official document
我想看清楚mrjob的官方例子
def mapper(self, _, line):
yield "chars", len(line)
yield "words", len(line.split())
yield "lines", 1
def reducer(self, key, values):
yield key, sum(values)
if __name__ == '__main__':
MRWordFrequencyCount.run()
我基本能理解MapReduce.but的思路了,这句话(yield "lines", 1)是怎么工作的呢? “1”是什么意思?
这段代码returns一个元组:("lines", 1)。在这种情况下,元组可以省略括号。每个 yield
returns 输入的某个方面,以及方面的值。行数为1.
该行可以这样写:
yield ("lines", 1)
我想看清楚mrjob的官方例子
def mapper(self, _, line):
yield "chars", len(line)
yield "words", len(line.split())
yield "lines", 1
def reducer(self, key, values):
yield key, sum(values)
if __name__ == '__main__':
MRWordFrequencyCount.run()
我基本能理解MapReduce.but的思路了,这句话(yield "lines", 1)是怎么工作的呢? “1”是什么意思?
这段代码returns一个元组:("lines", 1)。在这种情况下,元组可以省略括号。每个 yield
returns 输入的某个方面,以及方面的值。行数为1.
该行可以这样写:
yield ("lines", 1)