in src/main/java/com/hadoop/compression/lzo/LzoCompressor.java [318:331]
synchronized void setInputFromSavedData() {
if (0 >= userBufLen) {
return;
}
finished = false;
uncompressedDirectBufLen = Math.min(userBufLen, directBufferSize);
((ByteBuffer)uncompressedDirectBuf).put(userBuf, userBufOff,
uncompressedDirectBufLen);
// Note how much data is being fed to lzo
userBufOff += uncompressedDirectBufLen;
userBufLen -= uncompressedDirectBufLen;
}