Package 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	Description
private final 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 final int	IO_BUFFER_SIZE
private WALDecompressionBoundedDelegatingInputStream	lowerIn
private ByteArrayOutputStream	lowerOut

Constructor Summary

Constructors

Constructor	Description
ValueCompressor(Compression.Algorithm algorithm)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

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 WALDecompressionBoundedDelegatingInputStream lowerIn

lowerOut

private ByteArrayOutputStream lowerOut

compressedIn

private InputStream compressedIn

compressedOut

private OutputStream compressedOut

Constructor Details

ValueCompressor

public ValueCompressor(Compression.Algorithm algorithm)

Method Details

getAlgorithm

public Compression.Algorithm getAlgorithm()

compress

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

Throws:

IOException

decompress

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

Throws:

IOException

rawReadInt

private int rawReadInt(InputStream in)
                throws IOException

Throws:

IOException

clear

public void clear()