Нахождение среднего числа с помощью MapReduce

Я пытался написать код для нахождения среднего числа с помощью MapReduce.

Я пытаюсь использовать глобальные счетчики для достижения своей цели, но не могу установить значение счетчика в методе mapмоего Mapper, а также не могу получить значение счетчика в метод reduceмоего Reducer.

Должен ли я в любом случае использовать глобальный счетчик в map(например, с помощью incrCounter(key, amount)предоставленного Reporter)? Или вы могли бы предложить другую логику для получения среднего значения некоторых чисел?

7
задан witrin 21 February 2018 в 02:29
поделиться