Package 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, ByteBuffDecompressionCodec, org.apache.hadoop.io.compress.CompressionCodec, org.apache.hadoop.io.compress.DirectDecompressionCodec

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

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

Nested Class Summary

Nested Classes

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

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	Description
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ReusableStreamGzipCodec()

Method Summary

Modifier and Type	Method	Description
ByteBuffDecompressor	createByteBuffDecompressor()
org.apache.hadoop.io.compress.CompressionOutputStream	createOutputStream(OutputStream out)
Class<? extends ByteBuffDecompressor>	getByteBuffDecompressorType()
Compression.HFileDecompressionContext	getDecompressionContextFromConfiguration(org.apache.hadoop.conf.Configuration conf)

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 Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

ReusableStreamGzipCodec

public ReusableStreamGzipCodec()

Method Details

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

createByteBuffDecompressor

public ByteBuffDecompressor createByteBuffDecompressor()

Specified by:

createByteBuffDecompressor in interface ByteBuffDecompressionCodec

getByteBuffDecompressorType

public Class<? extends ByteBuffDecompressor> getByteBuffDecompressorType()

Specified by:

getByteBuffDecompressorType in interface ByteBuffDecompressionCodec

getDecompressionContextFromConfiguration

public Compression.HFileDecompressionContext getDecompressionContextFromConfiguration(org.apache.hadoop.conf.Configuration conf)

Specified by:

getDecompressionContextFromConfiguration in interface ByteBuffDecompressionCodec