Update LZ4Transcoder to match Compressed strategy factory type.

raunaqmorarka · Aug 29, 2015 · 413c0d1 · 413c0d1
1 parent 10af233
commit 413c0d1
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/server/src/main/java/io/druid/client/cache/LZ4Transcoder.java b/server/src/main/java/io/druid/client/cache/LZ4Transcoder.java
@@ -21,25 +21,24 @@
 import net.jpountz.lz4.LZ4Compressor;
 import net.jpountz.lz4.LZ4Decompressor;
 import net.jpountz.lz4.LZ4Factory;
+import net.jpountz.lz4.LZ4FastDecompressor;
 import net.spy.memcached.transcoders.SerializingTranscoder;
 
 import java.nio.ByteBuffer;
 
 public class LZ4Transcoder extends SerializingTranscoder
 {
 
-  private final LZ4Factory lz4Factory;
+  private final LZ4Factory lz4Factory = LZ4Factory.fastestInstance();
 
   public LZ4Transcoder()
   {
     super();
-    lz4Factory = LZ4Factory.fastestJavaInstance();
   }
 
   public LZ4Transcoder(int max)
   {
     super(max);
-    lz4Factory = LZ4Factory.fastestJavaInstance();
   }
 
   @Override
@@ -67,7 +66,7 @@ protected byte[] decompress(byte[] in)
   {
     byte[] out = null;
     if(in != null) {
-      LZ4Decompressor decompressor = lz4Factory.decompressor();
+      LZ4FastDecompressor decompressor = lz4Factory.fastDecompressor();
 
       int size = ByteBuffer.wrap(in).getInt();