org.apache.hadoop.hbase.io.compress

Class ReusableStreamGzipCodec

java.lang.Object

org.apache.hadoop.io.compress.DefaultCodec

org.apache.hadoop.io.compress.GzipCodec

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

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec, org.apache.hadoop.io.compress.DirectDecompressionCodec

@InterfaceAudience.Private
public class ReusableStreamGzipCodec
extends org.apache.hadoop.io.compress.GzipCodec

Fixes an inefficiency in Hadoop's Gzip codec, allowing to reuse compression streams.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ReusableStreamGzipCodec.ReusableGzipOutputStream A bridge that wraps around a DeflaterOutputStream to make it a CompressionOutputStream.

Nested classes/interfaces inherited from class org.apache.hadoop.io.compress.GzipCodec

org.apache.hadoop.io.compress.GzipCodec.GzipOutputStream

Nested classes/interfaces inherited from interface org.apache.hadoop.io.compress.CompressionCodec

org.apache.hadoop.io.compress.CompressionCodec.Util

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
ReusableStreamGzipCodec()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.compress.CompressionOutputStream	createOutputStream(OutputStream out)

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

createCompressor, createDecompressor, createDirectDecompressor, createInputStream, createInputStream, createOutputStream, getCompressorType, getDecompressorType, getDefaultExtension

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

getConf, setConf

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ReusableStreamGzipCodec

public ReusableStreamGzipCodec()

Method Detail

createOutputStream

public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out)
                                                                         throws IOException

Specified by:

createOutputStream in interface org.apache.hadoop.io.compress.CompressionCodec

Overrides:

createOutputStream in class org.apache.hadoop.io.compress.GzipCodec

Throws:

IOException