docs: @Override
      public RecordReader<Key, Value>
          createRecordReader(InputSplit split,
                             TaskAttemptContext context) throws IOException, InterruptedException {
          return new MasterTextRecordReader();
      }