Package com.linkedin.venice.compression

Class NoopCompressor

java.lang.Object

com.linkedin.venice.compression.VeniceCompressor

com.linkedin.venice.compression.NoopCompressor

All Implemented Interfaces:

Closeable, AutoCloseable

public class NoopCompressor
extends VeniceCompressor

Locking is not necessary for NoopCompressor, so this class overrides all the public APIs to avoid locking.

Field Summary

Fields inherited from class com.linkedin.venice.compression.VeniceCompressor

SCHEMA_HEADER_LENGTH

Constructor Summary

Constructors

Constructor	Description
NoopCompressor()

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	closeInternal()
byte[]	compress(byte[] data)
ByteBuffer	compress(ByteBuffer data, int startPositionOfOutput)
protected byte[]	compressInternal(byte[] data)
protected ByteBuffer	compressInternal(ByteBuffer src, int startPositionOfOutput)
ByteBuffer	decompress(byte[] data, int offset, int length)
InputStream	decompress(InputStream inputStream)
ByteBuffer	decompress(ByteBuffer data)
ByteBuffer	decompressAndPrependSchemaHeader(byte[] data, int offset, int length, int schemaHeader)	This method tries to decompress data and maybe prepend the schema header.
protected ByteBuffer	decompressAndPrependSchemaHeaderInternal(byte[] data, int offset, int length, int schemaHeader)
protected ByteBuffer	decompressInternal(byte[] data, int offset, int length)
protected InputStream	decompressInternal(InputStream inputStream)
protected ByteBuffer	decompressInternal(ByteBuffer data)
boolean	equals(Object o)
int	hashCode()

Methods inherited from class com.linkedin.venice.compression.VeniceCompressor

getCompressionStrategy

Methods inherited from class java.lang.Object

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

Constructor Details

NoopCompressor

public NoopCompressor()

Method Details

compress

public byte[] compress(byte[] data)
                throws IOException

Overrides:

compress in class VeniceCompressor

Throws:

IOException

compressInternal

protected byte[] compressInternal(byte[] data)
                           throws IOException

Specified by:

compressInternal in class VeniceCompressor

Throws:

IOException

compress

public ByteBuffer compress(ByteBuffer data,
 int startPositionOfOutput)
                    throws IOException

Overrides:

compress in class VeniceCompressor

Throws:

IOException

compressInternal

protected ByteBuffer compressInternal(ByteBuffer src,
 int startPositionOfOutput)
                               throws IOException

Specified by:

compressInternal in class VeniceCompressor

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

decompress

public ByteBuffer decompress(ByteBuffer data)
                      throws IOException

Overrides:

decompress in class VeniceCompressor

Throws:

IOException

decompressInternal

protected ByteBuffer decompressInternal(ByteBuffer data)
                                 throws IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

IOException

decompress

public ByteBuffer decompress(byte[] data,
 int offset,
 int length)
                      throws IOException

Overrides:

decompress in class VeniceCompressor

Throws:

IOException

decompressInternal

protected ByteBuffer decompressInternal(byte[] data,
 int offset,
 int length)
                                 throws IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

IOException

decompressAndPrependSchemaHeader

public ByteBuffer decompressAndPrependSchemaHeader(byte[] data,
 int offset,
 int length,
 int schemaHeader)
                                            throws IOException

Description copied from class: VeniceCompressor

This method tries to decompress data and maybe prepend the schema header. The returned ByteBuffer will be backed by byte array that starts with schema header, followed by the decompressed data. The ByteBuffer will be positioned at the beginning of the decompressed data and the remaining of the ByteBuffer will be the length of the decompressed data.

Overrides:

decompressAndPrependSchemaHeader in class VeniceCompressor

Throws:

IOException

decompressAndPrependSchemaHeaderInternal

protected ByteBuffer decompressAndPrependSchemaHeaderInternal(byte[] data,
 int offset,
 int length,
 int schemaHeader)
                                                       throws IOException

Specified by:

decompressAndPrependSchemaHeaderInternal in class VeniceCompressor

Throws:

IOException

decompress

public InputStream decompress(InputStream inputStream)
                       throws IOException

Overrides:

decompress in class VeniceCompressor

Throws:

IOException

decompressInternal

protected InputStream decompressInternal(InputStream inputStream)
                                  throws IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class VeniceCompressor

Throws:

IOException

closeInternal

protected void closeInternal()
                      throws IOException

Specified by:

closeInternal in class VeniceCompressor

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object