org.apache.hadoop.io.compress
Class BlockDecompressorStream
java.lang.Object
java.io.InputStream
org.apache.hadoop.io.compress.CompressionInputStream
org.apache.hadoop.io.compress.DecompressorStream
org.apache.hadoop.io.compress.BlockDecompressorStream
- All Implemented Interfaces:
- Closeable, Seekable
public class BlockDecompressorStream
- extends DecompressorStream
A DecompressorStream
which works
with 'block-based' based compression algorithms, as opposed to
'stream-based' compression algorithms.
Method Summary |
protected int |
decompress(byte[] b,
int off,
int len)
|
protected int |
getCompressedData()
|
void |
resetState()
Reset the decompressor to its initial state and discard any buffered data,
as the underlying stream may have been repositioned. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BlockDecompressorStream
public BlockDecompressorStream(InputStream in,
Decompressor decompressor,
int bufferSize)
throws IOException
- Create a
BlockDecompressorStream
.
- Parameters:
in
- input streamdecompressor
- decompressor to usebufferSize
- size of buffer
- Throws:
IOException
BlockDecompressorStream
public BlockDecompressorStream(InputStream in,
Decompressor decompressor)
throws IOException
- Create a
BlockDecompressorStream
.
- Parameters:
in
- input streamdecompressor
- decompressor to use
- Throws:
IOException
BlockDecompressorStream
protected BlockDecompressorStream(InputStream in)
throws IOException
- Throws:
IOException
decompress
protected int decompress(byte[] b,
int off,
int len)
throws IOException
- Overrides:
decompress
in class DecompressorStream
- Throws:
IOException
getCompressedData
protected int getCompressedData()
throws IOException
- Overrides:
getCompressedData
in class DecompressorStream
- Throws:
IOException
resetState
public void resetState()
throws IOException
- Description copied from class:
CompressionInputStream
- Reset the decompressor to its initial state and discard any buffered data,
as the underlying stream may have been repositioned.
- Overrides:
resetState
in class DecompressorStream
- Throws:
IOException
Copyright © 2009 The Apache Software Foundation