Package com.linkedin.venice.compression
Class NoopCompressor
- java.lang.Object
-
- com.linkedin.venice.compression.VeniceCompressor
-
- com.linkedin.venice.compression.NoopCompressor
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class NoopCompressor extends VeniceCompressor
-
-
Field Summary
-
Fields inherited from class com.linkedin.venice.compression.VeniceCompressor
SCHEMA_HEADER_LENGTH
-
-
Constructor Summary
Constructors Constructor Description NoopCompressor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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
close, getCompressionStrategy
-
-
-
-
Method Detail
-
compress
public byte[] compress(byte[] data) throws java.io.IOException
- Specified by:
compress
in classVeniceCompressor
- Throws:
java.io.IOException
-
compress
public java.nio.ByteBuffer compress(java.nio.ByteBuffer data, int startPositionOfOutput) throws java.io.IOException
- Specified by:
compress
in classVeniceCompressor
- Throws:
java.io.IOException
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
decompress
public java.nio.ByteBuffer decompress(java.nio.ByteBuffer data) throws java.io.IOException
- Specified by:
decompress
in classVeniceCompressor
- Throws:
java.io.IOException
-
decompress
public java.nio.ByteBuffer decompress(byte[] data, int offset, int length) throws java.io.IOException
- Specified by:
decompress
in classVeniceCompressor
- 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 classVeniceCompressor
- Throws:
java.io.IOException
-
decompress
public java.io.InputStream decompress(java.io.InputStream inputStream) throws java.io.IOException
- Specified by:
decompress
in classVeniceCompressor
- Throws:
java.io.IOException
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
-