记录读取器何时向Map器发送数据？
让我给你一个关于mapper和recordreader是如何联系的想法来回答这个问题。这是将数据发送到Map器的hadoop代码。1

RecordReader<K1, V1> input;

  K1 key = input.createKey();
  V1 value = input.createValue();

  while (input.next(key, value)) {
    // map pair to output
    mapper.map(key, value, output, reporter);
    if(incrProcCount) {
      reporter.incrCounter(SkipBadRecords.COUNTER_GROUP, 
          SkipBadRecords.COUNTER_MAP_PROCESSED_RECORDS, 1);
    }
  }

基本上，hadoop会调用 next 直到它回来 false ，每次通话时 key 以及 value 将获得新值。 Key 通常是到目前为止读取的字节 value 文件中的下一行。
将数据发送到mapper的代码在哪里？
这段代码在hadoop的源代码中（可能在mapcontextimpl类中），但它类似于我在代码段中编写的代码。
编辑：源代码位于maprunner。