Я превращу свой комментарий в ответ, чтобы его можно было принять.
Подкласс MRJob
при создании MRFindStdev
:
class MRFindStdev(MRJob):
def mapper(self, _, line):
# code...
попробуйте следующее
from statistics import stdev
import statistics
class deviation(MRJob):
def mapper(self, __, line):
for num in line.split(','):
yield None, int(num)
def reducer(self, __, numbr):
yield "deviation",statistics.stdev(numbr)
if __name__ == '__main__':
deviation.run()