Работа RecordReader в Hadoop

(новый API): класс Mapper по умолчанию имеет метод запуска, который выглядит следующим образом:

public void run(Context context) throws IOException, InterruptedException {
    setup(context);
    while (context.nextKeyValue()) {
        map(context.getCurrentKey(), context.getCurrentValue(), context);
    }
    cleanup(context);
}

Методы Context.nextKeyValue(), Context.getCurrentKey() и Context.getCurrentValue() являются оболочками для методов RecordReader. См. исходный файл src/mapred/org/apache/hadoop/mapreduce/MapContext.java.

Итак, этот цикл выполняется и вызывает метод map(K, V, Context) вашей реализации Mapper.

Конкретно, что еще вы хотели бы узнать?

org.apache.hadoop.mapred.MapTask — runNewMapper()

Шаги беса:

1. создает новый маппер

2. получить разделение ввода для картографа

3. получить рекордер для разделения

4. инициализировать считыватель записей

5. используя средство чтения записей, выполните итерацию через getNextKeyVal() и передайте ключ, val методу карты картографов

6. очистить