org.apache.hadoop.io.compress

类 CompressorStream

java.lang.Object

java.io.OutputStream

org.apache.hadoop.io.compress.CompressionOutputStream

org.apache.hadoop.io.compress.CompressorStream

所有已实现的接口:

Closeable, Flushable, AutoCloseable

直接已知子类:

BlockCompressorStream, GzipCodec.GzipOutputStream

public class CompressorStream
extends CompressionOutputStream

字段概要

字段

限定符和类型	字段和说明
protected byte[]	buffer
protected boolean	closed
protected Compressor	compressor

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

out

构造器概要

构造器

限定符	构造器和说明
protected	CompressorStream(OutputStream out) Allow derived classes to directly set the underlying stream.
	CompressorStream(OutputStream out, Compressor compressor)
	CompressorStream(OutputStream out, Compressor compressor, int bufferSize)

方法概要

方法

限定符和类型	方法和说明
void	close()
protected void	compress()
void	finish() Finishes writing compressed data to the output stream without closing the underlying stream.
void	resetState() Reset the compression to the initial state.
void	write(byte[] b, int off, int len) Write compressed bytes to the stream.
void	write(int b)

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

flush

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

write

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

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

字段详细资料

compressor

protected Compressor compressor

buffer

protected byte[] buffer

closed

protected boolean closed

构造器详细资料

CompressorStream

public CompressorStream(OutputStream out,
                Compressor compressor,
                int bufferSize)

CompressorStream

public CompressorStream(OutputStream out,
                Compressor compressor)

CompressorStream

protected CompressorStream(OutputStream out)

Allow derived classes to directly set the underlying stream.

参数:

out - Underlying output stream.

方法详细资料

write

public void write(byte[] b,
         int off,
         int len)
           throws IOException

从类复制的说明: CompressionOutputStream

Write compressed bytes to the stream. Made abstract to prevent leakage to underlying stream.

指定者:

write 在类中 CompressionOutputStream

抛出:

IOException

compress

protected void compress()
                 throws IOException

抛出:

IOException

finish

public void finish()
            throws IOException

从类复制的说明: CompressionOutputStream

Finishes writing compressed data to the output stream without closing the underlying stream.

指定者:

finish 在类中 CompressionOutputStream

抛出:

IOException

resetState

public void resetState()
                throws IOException

从类复制的说明: CompressionOutputStream

Reset the compression to the initial state. Does not reset the underlying stream.

指定者:

resetState 在类中 CompressionOutputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 CompressionOutputStream

抛出:

IOException

write

public void write(int b)
           throws IOException

指定者:

write 在类中 OutputStream

抛出:

IOException