static class WALCellCodec.CompressedKvDecoder extends BaseDecoder
BaseDecoder.PBIS
Modifier and Type | Field and Description |
---|---|
private CompressionContext |
compression |
private boolean |
hasTagCompression |
private boolean |
hasValueCompression |
in, LOG
Constructor and Description |
---|
CompressedKvDecoder(InputStream in,
CompressionContext compression) |
Modifier and Type | Method and Description |
---|---|
private static void |
checkLength(int len,
int max) |
protected Cell |
parseCell()
Extract a Cell.
|
private void |
readCompressedValue(InputStream in,
byte[] outArray,
int outOffset,
int expectedLength) |
private int |
readIntoArray(byte[] to,
int offset,
Dictionary dict) |
advance, current, getInputStream
private final CompressionContext compression
private final boolean hasValueCompression
private final boolean hasTagCompression
public CompressedKvDecoder(InputStream in, CompressionContext compression)
protected Cell parseCell() throws IOException
BaseDecoder
parseCell
in class BaseDecoder
IOException
private int readIntoArray(byte[] to, int offset, Dictionary dict) throws IOException
IOException
private static void checkLength(int len, int max) throws IOException
IOException
private void readCompressedValue(InputStream in, byte[] outArray, int outOffset, int expectedLength) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.