com.bigdata.io.compression

Class NOPRecordCompressor

java.lang.Object

com.bigdata.io.compression.NOPRecordCompressor

All Implemented Interfaces:

IRecordCompressor, Externalizable, Serializable

public class NOPRecordCompressor
extends Object
implements IRecordCompressor, Externalizable

A compressor that copies bytes without compression them.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static NOPRecordCompressor	INSTANCE
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
NOPRecordCompressor() (De-)serialization ctor.

Method Summary

Methods

Modifier and Type	Method and Description
void	compress(byte[] bytes, int off, int len, OutputStream os) Writes the bytes on the output stream.
void	compress(byte[] bytes, OutputStream os) Writes the bytes on 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 buf, OutputStream os) Writes the buffer on the output stream.
ByteBuffer	decompress(byte[] bin) Returns the argument wrapped as a ByteBuffer.
ByteBuffer	decompress(ByteBuffer bin) Returns the argument.
void	readExternal(ObjectInput arg0) NOP
void	writeExternal(ObjectOutput arg0) NOP

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

INSTANCE

public static final transient NOPRecordCompressor INSTANCE

Constructor Detail

NOPRecordCompressor

public NOPRecordCompressor()

(De-)serialization ctor.

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 buf,
            OutputStream os)

Writes the buffer on the output stream.

Specified by:

compress in interface IRecordCompressor

Parameters:

buf - 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)

Writes the bytes on 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)

Writes the bytes on 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)

Returns the argument.

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)

Returns the argument wrapped as a ByteBuffer.

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.

readExternal

public void readExternal(ObjectInput arg0)
                  throws IOException,
                         ClassNotFoundException

NOP

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput arg0)
                   throws IOException

NOP

Specified by:

writeExternal in interface Externalizable

Throws:

IOException