org.apache.hadoop.hbase.regionserver.wal

Class CompressionContext.ValueCompressor

java.lang.Object

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

Enclosing class:

CompressionContext

static class CompressionContext.ValueCompressor
extends Object

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 Compression.Algorithm	algorithm
private InputStream	compressedIn
private OutputStream	compressedOut
private org.apache.hadoop.io.compress.Compressor	compressor
private org.apache.hadoop.io.compress.Decompressor	decompressor
(package private) static int	IO_BUFFER_SIZE
private BoundedDelegatingInputStream	lowerIn
private ByteArrayOutputStream	lowerOut

Constructor Summary

Constructors

Constructor and Description
ValueCompressor(Compression.Algorithm algorithm)

Method Summary

Modifier and Type	Method and Description
void	clear()
byte[]	compress(byte[] valueArray, int valueOffset, int valueLength)
int	decompress(InputStream in, int inLength, byte[] outArray, int outOffset, int outLength)
Compression.Algorithm	getAlgorithm()

Methods inherited from class java.lang.Object

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

Field Detail

IO_BUFFER_SIZE

static final int IO_BUFFER_SIZE

See Also:

Constant Field Values

algorithm

private final Compression.Algorithm algorithm

compressor

private org.apache.hadoop.io.compress.Compressor compressor

decompressor

private org.apache.hadoop.io.compress.Decompressor decompressor

lowerIn

private BoundedDelegatingInputStream lowerIn

lowerOut

private ByteArrayOutputStream lowerOut

compressedIn

private InputStream compressedIn

compressedOut

private OutputStream compressedOut

Constructor Detail

ValueCompressor

public ValueCompressor(Compression.Algorithm algorithm)

Method Detail

getAlgorithm

public Compression.Algorithm getAlgorithm()

compress

public byte[] compress(byte[] valueArray,
                       int valueOffset,
                       int valueLength)
                throws IOException

Throws:

IOException

decompress

public int decompress(InputStream in,
                      int inLength,
                      byte[] outArray,
                      int outOffset,
                      int outLength)
               throws IOException

Throws:

IOException

clear

public void clear()