Field Detail

• rawKVs

  private byte[] rawKVs

• rawBuffer

  private ByteBuffer rawBuffer

• dataBlockEncoder

  private DataBlockEncoder dataBlockEncoder

• cachedEncodedData

  private byte[] cachedEncodedData

• encodingCtx

  private final HFileBlockEncodingContext encodingCtx

• meta

  private HFileContext meta

Constructor Detail

• EncodedDataBlock

  public EncodedDataBlock(DataBlockEncoder dataBlockEncoder,
                  DataBlockEncoding encoding,
                  byte[] rawKVs,
                  HFileContext meta)

  Create a buffer which will be encoded using dataBlockEncoder.

  Parameters:

  dataBlockEncoder - Algorithm used for compression.

  encoding - encoding type used

  rawKVs -

  meta -

Method Detail

• getIterator

  public Iterator<Cell> getIterator(int headerSize)

  Provides access to compressed value.

  Parameters:

  headerSize - header size of the block.

  Returns:

  Forwards sequential iterator.

• getSize

  public int getSize()

  Find the size of minimal buffer that could store compressed data.

  Returns:

  Size in bytes of compressed data.

• getCompressedSize

  public static int getCompressedSize(Compression.Algorithm algo,
                      org.apache.hadoop.io.compress.Compressor compressor,
                      byte[] inputBuffer,
                      int offset,
                      int length)
                               throws IOException

  Find the size of compressed data assuming that buffer will be compressed using given algorithm.

  Parameters:

  algo - compression algorithm

  compressor - compressor already requested from codec

  inputBuffer - Array to be compressed.

  offset - Offset to beginning of the data.

  length - Length to be compressed.

  Returns:

  Size of compressed data in bytes.

  Throws:

  IOException

• getEncodedCompressedSize

  public int getEncodedCompressedSize(Compression.Algorithm comprAlgo,
                             org.apache.hadoop.io.compress.Compressor compressor)
                               throws IOException

  Estimate size after second stage of compression (e.g. LZO).

  Parameters:

  comprAlgo - compression algorithm to be used for compression

  compressor - compressor corresponding to the given compression algorithm

  Returns:

  Size after second stage of compression.

  Throws:

  IOException

• getEncodedData

  private byte[] getEncodedData()

  Returns:

  encoded data with header

• getUncompressedBuffer

  private ByteBuffer getUncompressedBuffer()

• encodeData

  public byte[] encodeData()

  Do the encoding, but do not cache the encoded data.

  Returns:

  encoded data block with header and checksum

• toString

  public String toString()

  Overrides:

  toString in class Object