Package org.apache.hadoop.hbase.io.compress

Class ReusableStreamGzipCodec.ReusableGzipOutputStream

java.lang.Object

java.io.OutputStream

org.apache.hadoop.io.compress.CompressionOutputStream

org.apache.hadoop.io.compress.CompressorStream

org.apache.hadoop.hbase.io.compress.ReusableStreamGzipCodec.ReusableGzipOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, org.apache.hadoop.fs.statistics.IOStatisticsSource

Enclosing class:

ReusableStreamGzipCodec

protected static class ReusableStreamGzipCodec.ReusableGzipOutputStream
extends org.apache.hadoop.io.compress.CompressorStream

A bridge that wraps around a DeflaterOutputStream to make it a CompressionOutputStream.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ReusableStreamGzipCodec.ReusableGzipOutputStream.ResetableGZIPOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	GZIP_HEADER	Fixed ten-byte gzip header.
private static final int	GZIP_HEADER_LENGTH

Fields inherited from class org.apache.hadoop.io.compress.CompressorStream

buffer, closed, compressor

Fields inherited from class org.apache.hadoop.io.compress.CompressionOutputStream

out

Constructor Summary

Constructors

Constructor	Description
ReusableGzipOutputStream(OutputStream out)

Method Summary

Modifier and Type	Method	Description
void	close()
void	finish()
void	flush()
void	resetState()
void	write(byte[] data, int offset, int length)
void	write(int b)

Methods inherited from class org.apache.hadoop.io.compress.CompressorStream

compress

Methods inherited from class org.apache.hadoop.io.compress.CompressionOutputStream

getIOStatistics

Methods inherited from class java.io.OutputStream

nullOutputStream, write

Methods inherited from class java.lang.Object

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

Field Details

GZIP_HEADER_LENGTH

private static final int GZIP_HEADER_LENGTH

See Also:

• Constant Field Values

GZIP_HEADER

private static final byte[] GZIP_HEADER

Fixed ten-byte gzip header. See GZIPOutputStream's source for details.

Constructor Details

ReusableGzipOutputStream

public ReusableGzipOutputStream(OutputStream out)
                         throws IOException

Throws:

IOException

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class org.apache.hadoop.io.compress.CompressorStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class org.apache.hadoop.io.compress.CompressionOutputStream

Throws:

IOException

write

public void write(int b)
           throws IOException

Overrides:

write in class org.apache.hadoop.io.compress.CompressorStream

Throws:

IOException

write

public void write(byte[] data,
 int offset,
 int length)
           throws IOException

Overrides:

write in class org.apache.hadoop.io.compress.CompressorStream

Throws:

IOException

finish

public void finish()
            throws IOException

Overrides:

finish in class org.apache.hadoop.io.compress.CompressorStream

Throws:

IOException

resetState

public void resetState()
                throws IOException

Overrides:

resetState in class org.apache.hadoop.io.compress.CompressorStream

Throws:

IOException