org.apache.hadoop.hbase.regionserver.wal

Class CompressionContext

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.CompressionContext

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
public class CompressionContext
extends Object

Context that holds the various dictionaries for compression in WAL.

CompressionContexts are not expected to be shared among threads. Multithreaded use may produce unexpected results.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CompressionContext.DictionaryIndex
(package private) static class	CompressionContext.ValueCompressor Encapsulates the compression algorithm and its streams that we will use for value compression in this WAL.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<CompressionContext.DictionaryIndex,Dictionary>	dictionaries
static String	ENABLE_WAL_TAGS_COMPRESSION
static String	ENABLE_WAL_VALUE_COMPRESSION
private static org.slf4j.Logger	LOG
(package private) TagCompressionContext	tagCompressionContext
(package private) CompressionContext.ValueCompressor	valueCompressor
static String	WAL_VALUE_COMPRESSION_TYPE

Constructor Summary

Constructors

Constructor and Description
CompressionContext(Class<? extends Dictionary> dictType, boolean recoveredEdits, boolean hasTagCompression)
CompressionContext(Class<? extends Dictionary> dictType, boolean recoveredEdits, boolean hasTagCompression, boolean hasValueCompression, Compression.Algorithm valueCompressionType)

Method Summary

Modifier and Type	Method and Description
(package private) void	clear()
Dictionary	getDictionary(Enum dictIndex)
static Compression.Algorithm	getValueCompressionAlgorithm(org.apache.hadoop.conf.Configuration conf)
CompressionContext.ValueCompressor	getValueCompressor()
boolean	hasTagCompression()
boolean	hasValueCompression()

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

ENABLE_WAL_TAGS_COMPRESSION

public static final String ENABLE_WAL_TAGS_COMPRESSION

See Also:

Constant Field Values

ENABLE_WAL_VALUE_COMPRESSION

public static final String ENABLE_WAL_VALUE_COMPRESSION

See Also:

Constant Field Values

WAL_VALUE_COMPRESSION_TYPE

public static final String WAL_VALUE_COMPRESSION_TYPE

See Also:

Constant Field Values

dictionaries

private final Map<CompressionContext.DictionaryIndex,Dictionary> dictionaries

tagCompressionContext

TagCompressionContext tagCompressionContext

valueCompressor

CompressionContext.ValueCompressor valueCompressor

Constructor Detail

CompressionContext

public CompressionContext(Class<? extends Dictionary> dictType,
                          boolean recoveredEdits,
                          boolean hasTagCompression,
                          boolean hasValueCompression,
                          Compression.Algorithm valueCompressionType)
                   throws SecurityException,
                          NoSuchMethodException,
                          InstantiationException,
                          IllegalAccessException,
                          InvocationTargetException,
                          IOException

Throws:

SecurityException

NoSuchMethodException

InstantiationException

IllegalAccessException

InvocationTargetException

IOException

CompressionContext

public CompressionContext(Class<? extends Dictionary> dictType,
                          boolean recoveredEdits,
                          boolean hasTagCompression)
                   throws SecurityException,
                          NoSuchMethodException,
                          InstantiationException,
                          IllegalAccessException,
                          InvocationTargetException,
                          IOException

Throws:

SecurityException

NoSuchMethodException

InstantiationException

IllegalAccessException

InvocationTargetException

IOException

Method Detail

hasTagCompression

public boolean hasTagCompression()

hasValueCompression

public boolean hasValueCompression()

getDictionary

public Dictionary getDictionary(Enum dictIndex)

getValueCompressor

public CompressionContext.ValueCompressor getValueCompressor()

clear

void clear()

getValueCompressionAlgorithm

public static Compression.Algorithm getValueCompressionAlgorithm(org.apache.hadoop.conf.Configuration conf)