LRR_kv_while.java

while (getFilePosition() <= end || in.needAdditionalRecordAfterSplit()) {
  if (pos == 0) {
    newSize = skipUtfByteOrderMark();
  } else {
    newSize = in.readLine(value, maxLineLength, maxBytesToConsume(pos));
    pos += newSize;
  }

  if ((newSize == 0) || (newSize < maxLineLength)) {
    break;
  }

  // line too long. try again
  LOG.info("Skipped line of size " + newSize + " at pos " + 
           (pos - newSize));
}