in src/main/java/com/hadoop/compression/lzo/LzoCompressor.java [264:279]
private void init(CompressionStrategy strategy, int compressionLevel, int directBufferSize) {
this.strategy = strategy;
this.lzoCompressionLevel = compressionLevel;
this.directBufferSize = directBufferSize;
uncompressedDirectBuf = realloc(uncompressedDirectBuf, directBufferSize);
compressedDirectBuf = realloc(compressedDirectBuf, directBufferSize);
compressedDirectBuf.position(directBufferSize);
reset();
/**
* Initialize {@link #lzoCompress} and {@link #workingMemoryBufLen}
*/
init(this.strategy.getCompressor());
workingMemoryBuf = realloc(workingMemoryBuf, workingMemoryBufLen);
}