Package org.apache.cassandra.io.compress

Class NoopCompressor

java.lang.Object

org.apache.cassandra.io.compress.NoopCompressor

All Implemented Interfaces:

ICompressor

public class NoopCompressor
extends Object
implements ICompressor

A Compressor which doesn't actually compress any data. This is useful for either non-compressible data (typically already compressed or encrypted) that you still want block checksums for or for fast writing. Some relevant tickets:

• CASSANDRA-12682: Non compressed SSTables can silently corrupt data
• CASSANDRA-9264: Non compressed SSTables are written without checksums

Nested Class Summary

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

ICompressor.Uses

Constructor Summary

Constructors

Constructor	Description
NoopCompressor()

Method Summary

Modifier and Type	Method	Description
void	compress(ByteBuffer input, ByteBuffer output)	Compression for ByteBuffers.
static NoopCompressor	create(Map<String,String> ignored)
int	initialCompressedBufferLength(int chunkLength)
BufferType	preferredBufferType()	Returns the preferred (most efficient) buffer type for this compressor.
Set<String>	supportedOptions()
boolean	supports(BufferType bufferType)	Checks if the given buffer would be supported by the compressor.
int	uncompress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset)
void	uncompress(ByteBuffer input, ByteBuffer output)	Decompression for DirectByteBuffers.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.io.compress.ICompressor

recommendedUses

Constructor Details

NoopCompressor

public NoopCompressor()

Method Details

create

public static NoopCompressor create(Map<String,String> ignored)

initialCompressedBufferLength

public int initialCompressedBufferLength(int chunkLength)

Specified by:

initialCompressedBufferLength in interface ICompressor

uncompress

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

Specified by:

uncompress in interface ICompressor

Throws:

IOException

compress

public void compress(ByteBuffer input,
 ByteBuffer output)
              throws IOException

Description copied from interface: ICompressor

Compression for ByteBuffers. The data between input.position() and input.limit() is compressed and placed into output starting from output.position(). Positions in both buffers are moved to reflect the bytes read and written. Limits are not changed.

Specified by:

compress in interface ICompressor

Throws:

IOException

uncompress

public void uncompress(ByteBuffer input,
 ByteBuffer output)
                throws IOException

Description copied from interface: ICompressor

Decompression for DirectByteBuffers. The data between input.position() and input.limit() is uncompressed and placed into output starting from output.position(). Positions in both buffers are moved to reflect the bytes read and written. Limits are not changed.

Specified by:

uncompress in interface ICompressor

Throws:

IOException

preferredBufferType

public BufferType preferredBufferType()

Description copied from interface: ICompressor

Returns the preferred (most efficient) buffer type for this compressor.

Specified by:

preferredBufferType in interface ICompressor

supports

public boolean supports(BufferType bufferType)

Description copied from interface: ICompressor

Checks if the given buffer would be supported by the compressor. If a type is supported, the compressor must be able to use it in combination with all other supported types. Direct and memory-mapped buffers must be supported by all compressors.

Specified by:

supports in interface ICompressor

supportedOptions

public Set<String> supportedOptions()

Specified by:

supportedOptions in interface ICompressor