org.anarres.lzo.hadoop.codec

Class LzoCompressor

java.lang.Object

org.anarres.lzo.hadoop.codec.LzoCompressor

All Implemented Interfaces:

org.apache.hadoop.io.compress.Compressor

public class LzoCompressor
extends Object
implements org.apache.hadoop.io.compress.Compressor

A Compressor based on the lzo algorithm. http://www.oberhumer.com/opensource/lzo/

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LzoCompressor.CompressionStrategy The compression algorithm for lzo library.

Constructor Summary

Constructors

Constructor and Description
LzoCompressor() Creates a new compressor with the default lzo1x_1 compression.
LzoCompressor(LzoCompressor.CompressionStrategy strategy, int outputBufferSize) Creates a new compressor using the specified LzoCompressor.CompressionStrategy.

Method Summary

Modifier and Type	Method and Description
int	compress(byte[] b, int off, int len)
void	end() Noop.
void	finish()
boolean	finished()
long	getBytesRead() Return number of bytes given to this compressor since last reset.
long	getBytesWritten() Return number of bytes consumed by callers of compress since last reset.
boolean	needsInput()
void	reinit(org.apache.hadoop.conf.Configuration conf)
void	reset()
void	setDictionary(byte[] b, int off, int len)
void	setInput(byte[] b, int off, int len) WARNING: This method retains a pointer to the user's buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

LzoCompressor

public LzoCompressor(LzoCompressor.CompressionStrategy strategy,
                     int outputBufferSize)

Creates a new compressor using the specified LzoCompressor.CompressionStrategy.

Parameters:

strategy - lzo compression algorithm to use

outputBufferSize - size of the output buffer to be used.

LzoCompressor

public LzoCompressor()

Creates a new compressor with the default lzo1x_1 compression.

Method Detail

setInput

public void setInput(byte[] b,
                     int off,
                     int len)

WARNING: This method retains a pointer to the user's buffer.

Specified by:

setInput in interface org.apache.hadoop.io.compress.Compressor

setDictionary

public void setDictionary(byte[] b,
                          int off,
                          int len)

Specified by:

setDictionary in interface org.apache.hadoop.io.compress.Compressor

needsInput

public boolean needsInput()

Specified by:

needsInput in interface org.apache.hadoop.io.compress.Compressor

finish

public void finish()

Specified by:

finish in interface org.apache.hadoop.io.compress.Compressor

finished

public boolean finished()

Specified by:

finished in interface org.apache.hadoop.io.compress.Compressor

compress

public int compress(byte[] b,
                    int off,
                    int len)
             throws IOException

Specified by:

compress in interface org.apache.hadoop.io.compress.Compressor

Throws:

IOException

reset

public void reset()

Specified by:

reset in interface org.apache.hadoop.io.compress.Compressor

reinit

public void reinit(org.apache.hadoop.conf.Configuration conf)

Specified by:

reinit in interface org.apache.hadoop.io.compress.Compressor

getBytesRead

public long getBytesRead()

Return number of bytes given to this compressor since last reset.

Specified by:

getBytesRead in interface org.apache.hadoop.io.compress.Compressor

getBytesWritten

public long getBytesWritten()

Return number of bytes consumed by callers of compress since last reset.

Specified by:

getBytesWritten in interface org.apache.hadoop.io.compress.Compressor

end

public void end()

Noop.

Specified by:

end in interface org.apache.hadoop.io.compress.Compressor