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

Class ReusableStreamGzipCodec.ReusableGzipOutputStream.ResetableGZIPOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

java.util.zip.DeflaterOutputStream

java.util.zip.GZIPOutputStream

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

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Enclosing class:

ReusableStreamGzipCodec.ReusableGzipOutputStream

private static class ReusableStreamGzipCodec.ReusableGzipOutputStream.ResetableGZIPOutputStream
extends GZIPOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
private static final boolean	HAS_BROKEN_FINISH
private static final int	TRAILER_SIZE

Fields inherited from class java.util.zip.GZIPOutputStream

crc

Fields inherited from class java.util.zip.DeflaterOutputStream

buf, def

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor	Description
ResetableGZIPOutputStream(OutputStream out)

Method Summary

Modifier and Type	Method	Description
void	finish()	Override because certain implementation calls def.end() which causes problem when resetting the stream for reuse.
void	resetState()
private void	writeInt(int paramInt1, byte[] paramArrayOfByte, int paramInt2)	re-implement because the relative method in jdk is invisible
private void	writeShort(int paramInt1, byte[] paramArrayOfByte, int paramInt2)	re-implement because the relative method in jdk is invisible
private void	writeTrailer(byte[] paramArrayOfByte, int paramInt)	re-implement because the relative method in jdk is invisible

Methods inherited from class java.util.zip.GZIPOutputStream

write

Methods inherited from class java.util.zip.DeflaterOutputStream

close, deflate, flush, write

Methods inherited from class java.io.FilterOutputStream

write

Methods inherited from class java.lang.Object

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

Field Details

TRAILER_SIZE

private static final int TRAILER_SIZE

See Also:

• Constant Field Values

HAS_BROKEN_FINISH

private static final boolean HAS_BROKEN_FINISH

Constructor Details

ResetableGZIPOutputStream

public ResetableGZIPOutputStream(OutputStream out)
                          throws IOException

Throws:

IOException

Method Details

resetState

public void resetState()
                throws IOException

Throws:

IOException

finish

public void finish()
            throws IOException

Override because certain implementation calls def.end() which causes problem when resetting the stream for reuse.

Overrides:

finish in class GZIPOutputStream

Throws:

IOException

writeTrailer

private void writeTrailer(byte[] paramArrayOfByte,
 int paramInt)
                   throws IOException

re-implement because the relative method in jdk is invisible

Throws:

IOException

writeInt

private void writeInt(int paramInt1,
 byte[] paramArrayOfByte,
 int paramInt2)
               throws IOException

re-implement because the relative method in jdk is invisible

Throws:

IOException

writeShort

private void writeShort(int paramInt1,
 byte[] paramArrayOfByte,
 int paramInt2)
                 throws IOException

re-implement because the relative method in jdk is invisible

Throws:

IOException