@InterfaceAudience.Private public class EncodedDataBlock extends java.lang.Object
Constructor and Description |
---|
EncodedDataBlock(DataBlockEncoder dataBlockEncoder,
DataBlockEncoding encoding,
byte[] rawKVs,
HFileContext meta)
Create a buffer which will be encoded using dataBlockEncoder.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
encodeData()
Do the encoding, but do not cache the encoded data.
|
static int |
getCompressedSize(Compression.Algorithm algo,
Compressor compressor,
byte[] inputBuffer,
int offset,
int length)
Find the size of compressed data assuming that buffer will be compressed
using given algorithm.
|
int |
getEncodedCompressedSize(Compression.Algorithm comprAlgo,
Compressor compressor)
Estimate size after second stage of compression (e.g.
|
java.util.Iterator<Cell> |
getIterator(int headerSize)
Provides access to compressed value.
|
int |
getSize()
Find the size of minimal buffer that could store compressed data.
|
java.lang.String |
toString() |
public EncodedDataBlock(DataBlockEncoder dataBlockEncoder, DataBlockEncoding encoding, byte[] rawKVs, HFileContext meta)
dataBlockEncoder
- Algorithm used for compression.encoding
- encoding type usedrawKVs
- meta
- public java.util.Iterator<Cell> getIterator(int headerSize)
headerSize
- header size of the block.public int getSize()
public static int getCompressedSize(Compression.Algorithm algo, Compressor compressor, byte[] inputBuffer, int offset, int length) throws java.io.IOException
algo
- compression algorithmcompressor
- compressor already requested from codecinputBuffer
- Array to be compressed.offset
- Offset to beginning of the data.length
- Length to be compressed.java.io.IOException
public int getEncodedCompressedSize(Compression.Algorithm comprAlgo, Compressor compressor) throws java.io.IOException
comprAlgo
- compression algorithm to be used for compressioncompressor
- compressor corresponding to the given compression
algorithmjava.io.IOException
public byte[] encodeData()
public java.lang.String toString()
toString
in class java.lang.Object