static class CompressionContext.ValueCompressor extends Object
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 WALDecompressionBoundedDelegatingInputStream |
lowerIn |
private ByteArrayOutputStream |
lowerOut |
Constructor and Description |
---|
ValueCompressor(Compression.Algorithm algorithm) |
Modifier and Type | Method and 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) |
static final int IO_BUFFER_SIZE
private final Compression.Algorithm algorithm
private org.apache.hadoop.io.compress.Compressor compressor
private org.apache.hadoop.io.compress.Decompressor decompressor
private WALDecompressionBoundedDelegatingInputStream lowerIn
private ByteArrayOutputStream lowerOut
private InputStream compressedIn
private OutputStream compressedOut
public ValueCompressor(Compression.Algorithm algorithm)
public Compression.Algorithm getAlgorithm()
public byte[] compress(byte[] valueArray, int valueOffset, int valueLength) throws IOException
IOException
public void decompress(InputStream in, int inLength, byte[] outArray, int outOffset, int outLength) throws IOException
IOException
private int rawReadInt(InputStream in) throws IOException
IOException
public void clear()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.