public RecordReader getRecordReader()

in src/main/java/com/hadoop/mapred/DeprecatedLzoTextInputFormat.java [151:161]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public RecordReader<LongWritable, Text> getRecordReader(InputSplit split,
      JobConf conf, Reporter reporter) throws IOException {
    FileSplit fileSplit = (FileSplit) split;
    if (LzoInputFormatCommon.isLzoFile(fileSplit.getPath().toString())) {
      reporter.setStatus(split.toString());
      return new DeprecatedLzoLineRecordReader(conf, (FileSplit)split);
    } else {
      // delegate non-LZO files to the TextInputFormat base class.
      return super.getRecordReader(split, conf, reporter);
    }
  }