Package org.apache.hadoop.io.compress.snappy

Class SnappyDecompressor.SnappyDirectDecompressor

java.lang.Object

org.apache.hadoop.io.compress.snappy.SnappyDecompressor

org.apache.hadoop.io.compress.snappy.SnappyDecompressor.SnappyDirectDecompressor

All Implemented Interfaces:

Decompressor, DirectDecompressor

Enclosing class:

SnappyDecompressor

public static class SnappyDecompressor.SnappyDirectDecompressor
extends SnappyDecompressor
implements DirectDecompressor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.io.compress.snappy.SnappyDecompressor

SnappyDecompressor.SnappyDirectDecompressor

Constructor Summary

Constructors

Constructor	Description
SnappyDirectDecompressor()

Method Summary

Modifier and Type	Method	Description
int	decompress(byte[] b, int off, int len)	Fills specified buffer with uncompressed data.
void	decompress(ByteBuffer src, ByteBuffer dst)
boolean	finished()	Returns true if the end of the decompressed data output stream has been reached.
void	reset()	Resets decompressor and input and output buffers so that a new set of input data can be processed.
void	setDictionary(byte[] b, int off, int len)	Does nothing.

Methods inherited from class org.apache.hadoop.io.compress.snappy.SnappyDecompressor

end, getRemaining, needsDictionary, needsInput, setInput

Methods inherited from class java.lang.Object

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

Constructor Details

SnappyDirectDecompressor

public SnappyDirectDecompressor()

Method Details

finished

public boolean finished()

Description copied from class: SnappyDecompressor

Returns true if the end of the decompressed data output stream has been reached.

Specified by:

finished in interface Decompressor

Overrides:

finished in class SnappyDecompressor

Returns:

true if the end of the decompressed data output stream has been reached.

reset

public void reset()

Description copied from interface: Decompressor

Resets decompressor and input and output buffers so that a new set of input data can be processed. If Decompressor.finished()} returns true and Decompressor.getRemaining() returns a positive value, reset() is called before processing of the next data stream in the concatenated data stream. Decompressor.finished() will be reset and will return false when reset() is called.

Specified by:

reset in interface Decompressor

Overrides:

reset in class SnappyDecompressor

decompress

public void decompress(ByteBuffer src,
 ByteBuffer dst)
                throws IOException

Specified by:

decompress in interface DirectDecompressor

Throws:

IOException

setDictionary

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

Description copied from class: SnappyDecompressor

Does nothing.

Specified by:

setDictionary in interface Decompressor

Overrides:

setDictionary in class SnappyDecompressor

Parameters:

b - Dictionary data bytes

off - Start offset

len - Length

decompress

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

Description copied from class: SnappyDecompressor

Fills specified buffer with uncompressed data. Returns actual number of bytes of uncompressed data. A return value of 0 indicates that SnappyDecompressor.needsInput() should be called in order to determine if more input data is required.

Specified by:

decompress in interface Decompressor

Overrides:

decompress in class SnappyDecompressor

Parameters:

b - Buffer for the uncompressed data

off - Start offset of the data

len - Size of the buffer

Returns:

The actual number of bytes of compressed data.