Package com.linkedin.venice.compression

Class GzipCompressor

java.lang.Object

com.linkedin.venice.compression.VeniceCompressor

com.linkedin.venice.compression.GzipCompressor

All Implemented Interfaces:

Closeable, AutoCloseable

public class GzipCompressor
extends VeniceCompressor

Field Summary

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

SCHEMA_HEADER_LENGTH

Constructor Summary

Constructors

Constructor	Description
GzipCompressor()

Method Summary

Modifier and Type	Method	Description
protected void	closeInternal()
protected byte[]	compressInternal(byte[] data)
protected ByteBuffer	compressInternal(ByteBuffer data, int startPositionOfOutput)
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

close, compress, compress, decompress, decompress, decompress, decompressAndPrependSchemaHeader, getCompressionStrategy

Methods inherited from class java.lang.Object

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

Constructor Details

GzipCompressor

public GzipCompressor()

Method Details

compressInternal

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

Specified by:

compressInternal in class VeniceCompressor

Throws:

IOException

closeInternal

protected void closeInternal()
                      throws IOException

Specified by:

closeInternal in class VeniceCompressor

Throws:

IOException

compressInternal

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

Specified by:

compressInternal in class VeniceCompressor

Throws:

IOException

decompressInternal

protected ByteBuffer decompressInternal(ByteBuffer data)
                                 throws IOException

Specified by:

decompressInternal 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

decompressAndPrependSchemaHeaderInternal

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

Specified by:

decompressAndPrependSchemaHeaderInternal in class VeniceCompressor

Throws:

IOException

decompressInternal

protected InputStream decompressInternal(InputStream inputStream)
                                  throws IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object