org.apache.cassandra.transport.frame.compress

Class LZ4Compressor

java.lang.Object

org.apache.cassandra.transport.frame.compress.LZ4Compressor

All Implemented Interfaces:

Compressor

public class LZ4Compressor
extends java.lang.Object
implements Compressor

Field Summary

Fields

Modifier and Type	Field and Description
static LZ4Compressor	INSTANCE

Method Summary

Modifier and Type	Method and Description
int	compress(byte[] src, int srcOffset, int length, byte[] dest, int destOffset)
byte[]	decompress(byte[] src, int offset, int length, int expectedDecompressedLength)
int	maxCompressedLength(int length)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

public static final LZ4Compressor INSTANCE

Method Detail

maxCompressedLength

public int maxCompressedLength(int length)

Specified by:

maxCompressedLength in interface Compressor

Parameters:

length - the decompressed length being compressed

Returns:

the maximum length output possible for an input of the provided length

compress

public int compress(byte[] src,
                    int srcOffset,
                    int length,
                    byte[] dest,
                    int destOffset)
             throws java.io.IOException

Specified by:

compress in interface Compressor

Parameters:

src - the input bytes to be compressed

srcOffset - the offset to start compressing src from

length - the total number of bytes from srcOffset to pass to the compressor implementation

dest - the output buffer to write the compressed bytes to

destOffset - the offset into the dest buffer to start writing the compressed bytes

Returns:

the length of resulting compressed bytes written into the dest buffer

Throws:

java.io.IOException - if the compression implementation failed while compressing the input bytes

decompress

public byte[] decompress(byte[] src,
                         int offset,
                         int length,
                         int expectedDecompressedLength)
                  throws java.io.IOException

Specified by:

decompress in interface Compressor

Parameters:

src - the compressed bytes to be decompressed

expectedDecompressedLength - the expected length the input bytes will decompress to

Returns:

a byte[] containing the resuling decompressed bytes

Throws:

java.io.IOException - thrown if the compression implementation failed to decompress the provided input bytes