Class CompressionContext.ValueCompressor
java.lang.Object
org.apache.hadoop.hbase.regionserver.wal.CompressionContext.ValueCompressor
- Enclosing class:
- CompressionContext
Encapsulates the compression algorithm and its streams that we will use for value compression
in this WAL.
-
Field Summary
Modifier and TypeFieldDescriptionprivate final Compression.Algorithm
private InputStream
private OutputStream
private org.apache.hadoop.io.compress.Compressor
private org.apache.hadoop.io.compress.Decompressor
(package private) static final int
private ByteArrayOutputStream
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
clear()
byte[]
compress
(byte[] valueArray, int valueOffset, int valueLength) void
decompress
(InputStream in, int inLength, byte[] outArray, int outOffset, int outLength) private int
-
Field Details
-
IO_BUFFER_SIZE
- See Also:
-
algorithm
-
compressor
-
decompressor
-
lowerIn
-
lowerOut
-
compressedIn
-
compressedOut
-
-
Constructor Details
-
ValueCompressor
-
-
Method Details
-
getAlgorithm
-
compress
- Throws:
IOException
-
decompress
public void decompress(InputStream in, int inLength, byte[] outArray, int outOffset, int outLength) throws IOException - Throws:
IOException
-
rawReadInt
- Throws:
IOException
-
clear
-