public boolean nextKeyValue()

in src/main/java/com/hadoop/mapreduce/LzoLineRecordReader.java [120:138]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  public boolean nextKeyValue() throws IOException, InterruptedException {
    //since the lzop codec reads everything in lzo blocks
    //we can't stop if the pos == end
    //instead we wait for the next block to be read in when
    //pos will be > end
    while (pos <= end) {
      key.set(pos);

      int newSize = in.readLine(value);
      if (newSize == 0) {
        return false;
      }
      pos = fileIn.getPos();

      return true;
    }

    return false;
  }