import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
@Test
public void test() throws IOException {

    byte[] raw = new byte[] { 1, 2, 3, 3, 2, 23 };
    byte[] data = LZFEncoder.encode(raw);

    byte[] data2 = new byte[data.length * 2];
    java.lang.System.arraycopy(data, 0, data2, 0, data.length);
    ImmutableBytesWritable bytes = new ImmutableBytesWritable();
    bytes.set(data2, 0, data.length);

    try {
        byte[] uncompressed = LZFDecoder.decode(bytes.get(), bytes.getOffset(), bytes.getLength());
    } catch (IOException e) {
        throw new RuntimeException("LZF decode failure", e);
    }
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
private int _handleFiles(File dir) throws IOException {
    System.out.println("Testing files from dir '" + dir.getAbsolutePath() + "'...");
    int count = 0;
    for(File f: dir.listFiles()) {
        if(f.isDirectory()) {
            count += _handleFiles(f);
        } else {
            byte[] data = _readData(f);
            byte[] enc = LZFEncoder.encode(data);
            byte[] dec = LZFDecoder.decode(enc);
            assertArrayEquals("File '" + f.getAbsolutePath() + "'", data, dec);
            ++count;
        }
    }
    return count;
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
@Nonnull
@Override
public T readImpl(InputStream inputStream) throws IOException {
  int compressedSize = sizeCoder.readImpl(inputStream);
  return innerCoder.read(
      LZFDecoder.decode(
          StreamFns.readBytes(inputStream, compressedSize)));
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
/**
 * lzf 解壓縮
 *
 * @param value
 * @return
 */
public static byte[] unlzf(byte[] value) {
	byte[] result = new byte[0];
	try {
		result = LZFDecoder.decode(value);
	} catch (Exception ex) {
		ex.printStackTrace();
	}
	return result;
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
public void fromBytes(ImmutableBytesWritable bytes) {
    try {
        uncompressed = LZFDecoder.decode(bytes.get(), bytes.getOffset(), bytes.getLength());
    } catch (IOException e) {
        throw new RuntimeException("LZF decode failure", e);
    }
    size = cap = uncompressed.length / valueLen;
    compressed = BytesUtil.EMPTY_BYTE_ARRAY; // mark closed
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
public ByteBuffer decompress(byte[] b, int offset, int length) throws OperationFailedException {
	try {
		return ByteBuffer.wrap(LZFDecoder.decode(b, offset+3, length-3));
	} catch (CompressionFormatException e) {
		throw new OperationFailedException("Unexpected compression format");
	}
}
 

import com.ning.compress.lzf.LZFDecoder; //导入依赖的package包/类
public byte[] inflate(byte[] data) throws IOException {
    return LZFDecoder.decode(data);
}