in src/main/java/com/hadoop/compression/lzo/LzoCompressor.java [348:352]
public synchronized boolean finished() {
// Check if 'lzo' says its 'finished' and
// all compressed data has been consumed
return (finish && finished && compressedDirectBuf.remaining() == 0);
}