org.anarres.lzo.hadoop.codec

Class LzoDecompressor

java.lang.Object

org.anarres.lzo.hadoop.codec.LzoDecompressor

All Implemented Interfaces:

org.apache.hadoop.io.compress.Decompressor

public class LzoDecompressor
extends Object
implements org.apache.hadoop.io.compress.Decompressor

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LzoDecompressor.CompressionStrategy

Constructor Summary

Constructors

Constructor and Description
LzoDecompressor() Creates a new lzo decompressor.
LzoDecompressor(LzoDecompressor.CompressionStrategy strategy, int outputBufferSize) Creates a new lzo decompressor.

Method Summary

Modifier and Type	Method and Description
int	decompress(byte[] b, int off, int len)
void	end()
boolean	finished()
int	getRemaining()
boolean	needsDictionary()
boolean	needsInput()
void	reset()
void	setDictionary(byte[] b, int off, int len)
void	setInput(byte[] b, int off, int len)
void	setOutputBufferSize(int outputBufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

LzoDecompressor

public LzoDecompressor(LzoDecompressor.CompressionStrategy strategy,
                       int outputBufferSize)

Creates a new lzo decompressor.

Parameters:

strategy - lzo decompression algorithm

outputBufferSize - size of the output buffer

LzoDecompressor

public LzoDecompressor()

Creates a new lzo decompressor.

Method Detail

setOutputBufferSize

public void setOutputBufferSize(int outputBufferSize)

setInput

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

Specified by:

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

setDictionary

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

Specified by:

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

needsInput

public boolean needsInput()

Specified by:

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

needsDictionary

public boolean needsDictionary()

Specified by:

needsDictionary in interface org.apache.hadoop.io.compress.Decompressor

finished

public boolean finished()

Specified by:

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

decompress

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

Specified by:

decompress in interface org.apache.hadoop.io.compress.Decompressor

Throws:

IOException

getRemaining

public int getRemaining()

Specified by:

getRemaining in interface org.apache.hadoop.io.compress.Decompressor

reset

public void reset()

Specified by:

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

end

public void end()

Specified by:

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