Package com.linkedin.venice.compression

Class GzipCompressor

java.lang.Object

com.linkedin.venice.compression.VeniceCompressor

com.linkedin.venice.compression.GzipCompressor

All Implemented Interfaces:

java.io.Closeable, java.lang.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 java.nio.ByteBuffer	compressInternal(java.nio.ByteBuffer data, int startPositionOfOutput)
protected java.nio.ByteBuffer	decompressAndPrependSchemaHeaderInternal(byte[] data, int offset, int length, int schemaHeader)
protected java.nio.ByteBuffer	decompressInternal(byte[] data, int offset, int length)
protected java.io.InputStream	decompressInternal(java.io.InputStream inputStream)
protected java.nio.ByteBuffer	decompressInternal(java.nio.ByteBuffer data)
boolean	equals(java.lang.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 Detail

GzipCompressor

public GzipCompressor()

Method Detail

compressInternal

protected byte[] compressInternal(byte[] data)
                           throws java.io.IOException

Specified by:

compressInternal in class VeniceCompressor

Throws:

java.io.IOException

closeInternal

protected void closeInternal()
                      throws java.io.IOException

Specified by:

closeInternal in class VeniceCompressor

Throws:

java.io.IOException

compressInternal

protected java.nio.ByteBuffer compressInternal(java.nio.ByteBuffer data,
                                               int startPositionOfOutput)
                                        throws java.io.IOException

Specified by:

compressInternal in class VeniceCompressor

Throws:

java.io.IOException

decompressInternal

protected java.nio.ByteBuffer decompressInternal(java.nio.ByteBuffer data)
                                          throws java.io.IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

java.io.IOException

decompressInternal

protected java.nio.ByteBuffer decompressInternal(byte[] data,
                                                 int offset,
                                                 int length)
                                          throws java.io.IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

java.io.IOException

decompressAndPrependSchemaHeaderInternal

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

Specified by:

decompressAndPrependSchemaHeaderInternal in class VeniceCompressor

Throws:

java.io.IOException

decompressInternal

protected java.io.InputStream decompressInternal(java.io.InputStream inputStream)
                                          throws java.io.IOException

Specified by:

decompressInternal in class VeniceCompressor

Throws:

java.io.IOException

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object