org.apache.hadoop.io.compress

クラス CompressionInputStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.io.compress.CompressionInputStream

すべての実装されたインタフェース:

Closeable, AutoCloseable, Seekable

直系の既知のサブクラス:

DecompressorStream, SplitCompressionInputStream

@InterfaceAudience.Public
 @InterfaceStability.Evolving
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.

例外:

UnsupportedOperationException