in src/main/java/com/hadoop/mapred/DeprecatedLzoLineRecordReader.java [79:93]
public boolean next(LongWritable key, Text value) throws IOException {
// Since the LZOP codec reads everything in LZO blocks, we can't stop if pos == end.
// Instead, 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;
}