org.apache.hadoop.io.compress

类 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

所有已实现的接口:

Closeable, AutoCloseable, Seekable

public class BlockDecompressorStream
extends DecompressorStream

A DecompressorStream which works with 'block-based' based compression algorithms, as opposed to 'stream-based' compression algorithms.

字段概要

从类继承的字段 org.apache.hadoop.io.compress.DecompressorStream

buffer, closed, decompressor, eof

从类继承的字段 org.apache.hadoop.io.compress.CompressionInputStream

in, maxAvailableData

构造器概要

构造器

限定符	构造器和说明
protected	BlockDecompressorStream(InputStream in)
	BlockDecompressorStream(InputStream in, Decompressor decompressor) Create a BlockDecompressorStream.
	BlockDecompressorStream(InputStream in, Decompressor decompressor, int bufferSize) Create a BlockDecompressorStream.

方法概要

方法

限定符和类型	方法和说明
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.

从类继承的方法 org.apache.hadoop.io.compress.DecompressorStream

available, checkStream, close, mark, markSupported, read, read, reset, skip

从类继承的方法 org.apache.hadoop.io.compress.CompressionInputStream

getPos, seek, seekToNewSource

从类继承的方法 java.io.InputStream

read

从类继承的方法 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.

参数:

in - input stream

decompressor - decompressor to use

bufferSize - size of buffer

抛出:

IOException

BlockDecompressorStream

public BlockDecompressorStream(InputStream in,
                       Decompressor decompressor)
                        throws IOException

Create a BlockDecompressorStream.

参数:

in - input stream

decompressor - decompressor to use

抛出:

IOException

BlockDecompressorStream

protected BlockDecompressorStream(InputStream in)
                           throws IOException

抛出:

IOException

方法详细资料

decompress

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

覆盖:

decompress 在类中 DecompressorStream

抛出:

IOException

getCompressedData

protected int getCompressedData()
                         throws IOException

覆盖:

getCompressedData 在类中 DecompressorStream

抛出:

IOException

resetState

public void resetState()
                throws IOException

从类复制的说明: CompressionInputStream

Reset the decompressor to its initial state and discard any buffered data, as the underlying stream may have been repositioned.

覆盖:

resetState 在类中 DecompressorStream

抛出:

IOException