ZeD.ORA,

Честно говоря времени не очень много, код посмотрел по диагонали, выглядит странно.

В целом всё просто, для файла:

1) берём файл, режем его на куски по N байт. (если взять hdfs, то файл уже разделён на блоки по N байт, по умолчанию, 128 мб или 256 мб, не помню )

2) каждую строку мы скармливаем методу Mapper.map(Key, Value), где что-то делаем c данными.

3) после работы map у нас накапливается список каких-то результирующих Key-Value строк.

3*) мы можем использовать Combiner, это маленький reducer, который может подготовить данные перед передачей на reduce. В целом предназначен для уменьшения сетевого трафика и ускорения.

4) мы их копируем на ноды, где будет происходить reduce, причём разделяем их по результату некой хеш-функции, которую мы можем переопределять

5) на каждой ноде происходит сортировка входных данных

6) собственно Reducer.reduce(Key, Value), где Key, Value - это результаты работы Mapper.map

ZeD.ORA,

Кстати, важный нюанс - есть map-only задачи. То есть задачи, в которых только первые 3 пункта.