Constructor Detail

• CopyKeyDataBlockEncoder

  public CopyKeyDataBlockEncoder()

Method Detail

• startBlockEncoding

  public void startBlockEncoding(HFileBlockEncodingContext blkEncodingCtx,
                        DataOutputStream out)
                          throws IOException

  Description copied from interface: DataBlockEncoder
  Starts encoding for a block of KeyValues. Call DataBlockEncoder.endBlockEncoding(HFileBlockEncodingContext, DataOutputStream, byte[]) to finish encoding of a block.

  Specified by:

  startBlockEncoding in interface DataBlockEncoder

  Throws:

  IOException

• internalEncode

  public int internalEncode(Cell cell,
                   HFileBlockDefaultEncodingContext encodingContext,
                   DataOutputStream out)
                     throws IOException

  Throws:

  IOException

• getFirstKeyInBlock

  public ByteBuffer getFirstKeyInBlock(ByteBuffer block)

  Description copied from interface: DataBlockEncoder
  Return first key in block. Useful for indexing. Typically does not make a deep copy but returns a buffer wrapping a segment of the actual block's byte array. This is because the first key in block is usually stored unencoded.

  Parameters:

  block - encoded block we want index, the position will not change

  Returns:

  First key in block.

• toString

  public String toString()

  Overrides:

  toString in class Object

• createSeeker

  public DataBlockEncoder.EncodedSeeker createSeeker(KeyValue.KVComparator comparator,
                                            HFileBlockDecodingContext decodingCtx)

  Description copied from interface: DataBlockEncoder
  Create a HFileBlock seeker which find KeyValues within a block.

  Parameters:

  comparator - what kind of comparison should be used

  Returns:

  A newly created seeker.

• internalDecodeKeyValues

  protected ByteBuffer internalDecodeKeyValues(DataInputStream source,
                                   int allocateHeaderLength,
                                   int skipLastBytes,
                                   HFileBlockDefaultDecodingContext decodingCtx)
                                        throws IOException

  Throws:

  IOException

• decodeKeyValues

  public ByteBuffer decodeKeyValues(DataInputStream source,
                           HFileBlockDecodingContext blkDecodingCtx)
                             throws IOException

  Description copied from interface: DataBlockEncoder
  Decode.

  Parameters:

  source - Compressed stream of KeyValues.

  Returns:

  Uncompressed block of KeyValues.

  Throws:

  IOException - If there is an error in source.

• afterEncodingKeyValue

  protected final int afterEncodingKeyValue(Cell cell,
                          DataOutputStream out,
                          HFileBlockDefaultEncodingContext encodingCtx)
                                     throws IOException

  Parameters:

  cell -

  out -

  encodingCtx -

  Returns:

  unencoded size added

  Throws:

  IOException

• afterDecodingKeyValue

  protected final void afterDecodingKeyValue(DataInputStream source,
                           ByteBuffer dest,
                           HFileBlockDefaultDecodingContext decodingCtx)
                                      throws IOException

  Throws:

  IOException

• ensureSpace

  protected static void ensureSpace(ByteBuffer out,
                 int length)
                             throws EncoderBufferTooSmallException

  Asserts that there is at least the given amount of unfilled space remaining in the given buffer.

  Parameters:

  out - typically, the buffer we are writing to

  length - the required space in the buffer

  Throws:

  EncoderBufferTooSmallException - If there are no enough bytes.

• encode

  public int encode(Cell cell,
           HFileBlockEncodingContext encodingCtx,
           DataOutputStream out)
             throws IOException

  Description copied from interface: DataBlockEncoder
  Encodes a KeyValue.

  Returns:

  unencoded kv size written

  Throws:

  IOException

• endBlockEncoding

  public void endBlockEncoding(HFileBlockEncodingContext encodingCtx,
                      DataOutputStream out,
                      byte[] uncompressedBytesWithHeader)
                        throws IOException

  Description copied from interface: DataBlockEncoder
  Ends encoding for a block of KeyValues. Gives a chance for the encoder to do the finishing stuff for the encoded block. It must be called at the end of block encoding.

  Throws:

  IOException