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 and Description
private static boolean	HAS_BROKEN_FINISH
private static 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 and Description
ResetableGZIPOutputStream(OutputStream out)

Method Summary

Modifier and Type	Method and 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 Detail

TRAILER_SIZE

private static final int TRAILER_SIZE

See Also:

Constant Field Values

HAS_BROKEN_FINISH

private static final boolean HAS_BROKEN_FINISH

Constructor Detail

ResetableGZIPOutputStream

public ResetableGZIPOutputStream(OutputStream out)
                          throws IOException

Throws:

IOException

Method Detail

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