Python Mapreduce - средний - PullRequest
Новая
       11

Python Mapreduce - средний

0 голосов
/ 30 ноября 2018

Код Python: 

#!/usr/bin/python
#Reducer.py
import sys

age_balance = {}

#Partitoner
for line in sys.stdin:
    line = line.strip()
    age, balance = line.split('\t')

    if age in age_balance:
        age_balance[age].append(int(balance))
    else:
        age_balance[age] = []
        age_balance[age].append(int(balance))

#Reducer
for age in age_balance.keys():
    ave_age = sum(age_balance[age])*1.0 / len(age_balance[age])
    print '%s\t%s'% (age, ave_age)

Привет, я получаю сообщение об ошибке: Файл "C: \ Code \ study \ reducer.py", строка 16, в age_balance [balance] .append (int ((age)) ValueError: недопустимый литерал для int () с основанием 10: «age» Процесс попытался записать в несуществующий канал.

Это образец данных, которые я пытаюсь получитьсреднее значение:

...