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
void	close()
byte[]	compress(byte[] data)
java.nio.ByteBuffer	compress(java.nio.ByteBuffer data, int startPositionOfOutput)
java.nio.ByteBuffer	decompress(byte[] data, int offset, int length)
java.io.InputStream	decompress(java.io.InputStream inputStream)
java.nio.ByteBuffer	decompress(java.nio.ByteBuffer data)
java.nio.ByteBuffer	decompressAndPrependSchemaHeader(byte[] data, int offset, int length, int schemaHeader)	This method tries to decompress data and maybe prepend the schema header.
boolean	equals(java.lang.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 Detail

GzipCompressor

public GzipCompressor()

Method Detail

compress

public byte[] compress(byte[] data)
                throws java.io.IOException

Specified by:

compress in class VeniceCompressor

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class VeniceCompressor

Throws:

java.io.IOException

compress

public java.nio.ByteBuffer compress(java.nio.ByteBuffer data,
                                    int startPositionOfOutput)
                             throws java.io.IOException

Specified by:

compress in class VeniceCompressor

Throws:

java.io.IOException

decompress

public java.nio.ByteBuffer decompress(java.nio.ByteBuffer data)
                               throws java.io.IOException

Specified by:

decompress in class VeniceCompressor

Throws:

java.io.IOException

decompress

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

Specified by:

decompress in class VeniceCompressor

Throws:

java.io.IOException

decompressAndPrependSchemaHeader

public java.nio.ByteBuffer decompressAndPrependSchemaHeader(byte[] data,
                                                            int offset,
                                                            int length,
                                                            int schemaHeader)
                                                     throws java.io.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.

Specified by:

decompressAndPrependSchemaHeader in class VeniceCompressor

Throws:

java.io.IOException

decompress

public java.io.InputStream decompress(java.io.InputStream inputStream)
                               throws java.io.IOException

Specified by:

decompress 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