com.bigdata.io.compression

Class GZipCompressor

java.lang.Object

com.bigdata.io.compression.GZipCompressor

All Implemented Interfaces:

IRecordCompressor

public class GZipCompressor
extends Object
implements IRecordCompressor

Constructor Summary

Constructors

Constructor and Description
GZipCompressor()

Method Summary

Methods

Modifier and Type	Method and Description
void	compress(byte[] bytes, int off, int len, OutputStream os) Compresses data onto the output stream.
void	compress(byte[] bytes, OutputStream os) Compresses data onto the output stream.
ByteBuffer	compress(ByteBuffer bin) Compresses data onto the provided ByteBuffer.
void	compress(ByteBuffer bin, ByteBuffer out) Compresses data onto the provided ByteBuffer.
void	compress(ByteBuffer bin, OutputStream os) Compresses data onto the output stream.
ByteBuffer	decompress(byte[] bin) Decompress a byte[] containing the record and return the uncompressed state.
ByteBuffer	decompress(ByteBuffer bin) Decompress a ByteBuffer containing the record and return the uncompressed state.
ByteBuffer	decompress(InputStream instr)

Methods inherited from class java.lang.Object

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

Constructor Detail

GZipCompressor

public GZipCompressor()

Method Detail

compress

public void compress(ByteBuffer bin,
            ByteBuffer out)

Description copied from interface: IRecordCompressor

Compresses data onto the provided ByteBuffer.

Specified by:

compress in interface IRecordCompressor

Parameters:

bin - The data. The data from the position to the limit will be compressed. The position will be advanced to the limit as a side effect.

out - The ByteBuffer into which the compressed data is written

compress

public ByteBuffer compress(ByteBuffer bin)

Description copied from interface: IRecordCompressor

Compresses data onto the provided ByteBuffer.

Specified by:

compress in interface IRecordCompressor

Parameters:

bin - The data. The data from the position to the limit will be compressed. The position will be advanced to the limit as a side effect.

Returns:

The ByteBuffer into which the compressed data is written

compress

public void compress(ByteBuffer bin,
            OutputStream os)

Description copied from interface: IRecordCompressor

Compresses data onto the output stream.

Specified by:

compress in interface IRecordCompressor

Parameters:

bin - The data. The data from the position to the limit will be compressed. The position will be advanced to the limit as a side effect.

os - The stream onto which the compressed data are written.

compress

public void compress(byte[] bytes,
            OutputStream os)

Description copied from interface: IRecordCompressor

Compresses data onto the output stream.

Specified by:

compress in interface IRecordCompressor

Parameters:

bytes - The data.

os - The stream onto which the compressed data are written.

compress

public void compress(byte[] bytes,
            int off,
            int len,
            OutputStream os)

Description copied from interface: IRecordCompressor

Compresses data onto the output stream.

Specified by:

compress in interface IRecordCompressor

Parameters:

bytes - The source data.

off - The offset of the first source byte that will be compressed onto the output stream.

len - The #of source bytes that will be compressed onto the output stream.

os - The stream onto which the compressed data are written.

decompress

public ByteBuffer decompress(ByteBuffer bin)

Description copied from interface: IRecordCompressor

Decompress a ByteBuffer containing the record and return the uncompressed state.

Specified by:

decompress in interface IRecordCompressor

Parameters:

bin - The compressed data.

Returns:

A view onto a shared buffer. The data between position() and limit() are the decompressed data. The contents of this buffer are valid only until the next compression or decompression request.

decompress

public ByteBuffer decompress(byte[] bin)

Description copied from interface: IRecordCompressor

Decompress a byte[] containing the record and return the uncompressed state.

Specified by:

decompress in interface IRecordCompressor

Parameters:

bin - The compressed data.

Returns:

A read-only view onto a shared buffer. The data between position() and limit() are the decompressed data. The contents of this buffer are valid only until the next compression or decompression request. The position will be zero. The limit will be the #of decompressed bytes.

decompress

public ByteBuffer decompress(InputStream instr)