org.apache.hadoop.io.compress

类 CompressionInputStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.io.compress.CompressionInputStream

所有已实现的接口:

Closeable, AutoCloseable, Seekable

直接已知子类:

DecompressorStream, SplitCompressionInputStream

public abstract class CompressionInputStream
extends InputStream
implements Seekable

A compression input stream.

Implementations are assumed to be buffered. This permits clients to reposition the underlying input stream then call resetState(), without having to also synchronize client buffers.

字段概要

字段

限定符和类型	字段和说明
protected InputStream	in The input stream to be compressed.
protected long	maxAvailableData

构造器概要

构造器

限定符	构造器和说明
protected	CompressionInputStream(InputStream in) Create a compression input stream that reads the decompressed bytes from the given stream.

方法概要

方法

限定符和类型	方法和说明
void	close()
long	getPos() This method returns the current position in the stream.
abstract int	read(byte[] b, int off, int len) Read bytes from the stream.
abstract void	resetState() Reset the decompressor to its initial state and discard any buffered data, as the underlying stream may have been repositioned.
void	seek(long pos) This method is current not supported.
boolean	seekToNewSource(long targetPos) This method is current not supported.

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

available, mark, markSupported, read, read, reset, skip

从类继承的方法 java.lang.Object

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

字段详细资料

in

protected final InputStream in

The input stream to be compressed.

maxAvailableData

protected long maxAvailableData

构造器详细资料

CompressionInputStream

protected CompressionInputStream(InputStream in)
                          throws IOException

Create a compression input stream that reads the decompressed bytes from the given stream.

参数:

in - The input stream to be compressed.

抛出:

IOException

方法详细资料

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 InputStream

抛出:

IOException

read

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

Read bytes from the stream. Made abstract to prevent leakage to underlying stream.

覆盖:

read 在类中 InputStream

抛出:

IOException

resetState

public abstract void resetState()
                         throws IOException

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

抛出:

IOException

getPos

public long getPos()
            throws IOException

This method returns the current position in the stream.

指定者:

getPos 在接口中 Seekable

返回:

Current position in stream as a long

抛出:

IOException

seek

public void seek(long pos)
          throws UnsupportedOperationException

This method is current not supported.

指定者:

seek 在接口中 Seekable

抛出:

UnsupportedOperationException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws UnsupportedOperationException

This method is current not supported.

指定者:

seekToNewSource 在接口中 Seekable

抛出:

UnsupportedOperationException