org.apache.cassandra.io.compress

Class DeflateCompressor

java.lang.Object

org.apache.cassandra.io.compress.DeflateCompressor

All Implemented Interfaces:

ICompressor

public class DeflateCompressor
extends java.lang.Object
implements ICompressor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.io.compress.ICompressor

ICompressor.WrappedByteBuffer

Field Summary

Fields

Modifier and Type	Field and Description
static DeflateCompressor	instance

Method Summary

Modifier and Type	Method and Description
int	compress(java.nio.ByteBuffer src, ICompressor.WrappedByteBuffer dest) Compression for ByteBuffers
static DeflateCompressor	create(java.util.Map<java.lang.String,java.lang.String> compressionOptions)
int	initialCompressedBufferLength(int chunkLength)
java.util.Set<java.lang.String>	supportedOptions()
int	uncompress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset)
int	uncompress(java.nio.ByteBuffer input, java.nio.ByteBuffer output) Decompression for DirectByteBuffers
boolean	useDirectOutputByteBuffers() Notifies user if this compressor will wants/requires a direct byte buffers to decompress direct byteBuffers

Methods inherited from class java.lang.Object

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

Field Detail

instance

public static final DeflateCompressor instance

Method Detail

create

public static DeflateCompressor create(java.util.Map<java.lang.String,java.lang.String> compressionOptions)

supportedOptions

public java.util.Set<java.lang.String> supportedOptions()

Specified by:

supportedOptions in interface ICompressor

initialCompressedBufferLength

public int initialCompressedBufferLength(int chunkLength)

Specified by:

initialCompressedBufferLength in interface ICompressor

compress

public int compress(java.nio.ByteBuffer src,
                    ICompressor.WrappedByteBuffer dest)

Description copied from interface: ICompressor

Compression for ByteBuffers

Specified by:

compress in interface ICompressor

uncompress

public int uncompress(byte[] input,
                      int inputOffset,
                      int inputLength,
                      byte[] output,
                      int outputOffset)
               throws java.io.IOException

Specified by:

uncompress in interface ICompressor

Throws:

java.io.IOException

uncompress

public int uncompress(java.nio.ByteBuffer input,
                      java.nio.ByteBuffer output)
               throws java.io.IOException

Description copied from interface: ICompressor

Decompression for DirectByteBuffers

Specified by:

uncompress in interface ICompressor

Throws:

java.io.IOException

useDirectOutputByteBuffers

public boolean useDirectOutputByteBuffers()

Description copied from interface: ICompressor

Notifies user if this compressor will wants/requires a direct byte buffers to decompress direct byteBuffers

Specified by:

useDirectOutputByteBuffers in interface ICompressor