org.apache.hadoop.hbase.io.compress

Class Compression

java.lang.Object

org.apache.hadoop.hbase.io.compress.Compression

@InterfaceAudience.Private
public final class Compression
extends Object

Compression related stuff. Copied from hadoop-3315 tfile.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Compression.Algorithm Compression algorithms.
(package private) static class	Compression.FinishOnFlushCompressionStream

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Compression() Prevent the instantiation of class.

Method Summary

Modifier and Type	Method and Description
static void	decompress(ByteBuff dest, InputStream bufferedBoundedStream, int uncompressedSize, Compression.Algorithm compressAlgo) Decompresses data from the given stream using the configured compression algorithm.
private static ClassLoader	getClassLoaderForCodec() Returns the classloader to load the Codec class from.
static Compression.Algorithm	getCompressionAlgorithmByName(String compressName)
static String[]	getSupportedAlgorithms() Get names of supported compression algorithms.

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

Compression

private Compression()

Prevent the instantiation of class.

Method Detail

getClassLoaderForCodec

private static ClassLoader getClassLoaderForCodec()

Returns the classloader to load the Codec class from.

getCompressionAlgorithmByName

public static Compression.Algorithm getCompressionAlgorithmByName(String compressName)

getSupportedAlgorithms

public static String[] getSupportedAlgorithms()

Get names of supported compression algorithms.

Returns:

Array of strings, each represents a supported compression algorithm. Currently, the following compression algorithms are supported.

decompress

public static void decompress(ByteBuff dest,
                              InputStream bufferedBoundedStream,
                              int uncompressedSize,
                              Compression.Algorithm compressAlgo)
                       throws IOException

Decompresses data from the given stream using the configured compression algorithm. It will throw an exception if the dest buffer does not have enough space to hold the decompressed data.

Parameters:

dest - the output buffer

bufferedBoundedStream - a stream to read compressed data from, bounded to the exact amount of compressed data

uncompressedSize - uncompressed data size, header not included

compressAlgo - compression algorithm used

Throws:

IOException - if any IO error happen