org.apache.hadoop.hbase.io.encoding

Class DiffKeyDeltaEncoder

java.lang.Object

org.apache.hadoop.hbase.io.encoding.DiffKeyDeltaEncoder

All Implemented Interfaces:

DataBlockEncoder

@InterfaceAudience.Private
public class DiffKeyDeltaEncoder
extends java.lang.Object

Compress using: - store size of common prefix - save column family once, it is same within HFile - use integer compression for key, value and prefix (7-bit encoding) - use bits to avoid duplication key length, value length and type if it same as previous - store in 3 bits length of timestamp field - allow diff in timestamp instead of actual value Format: - 1 byte: flag - 1-5 bytes: key length (only if FLAG_SAME_KEY_LENGTH is not set in flag) - 1-5 bytes: value length (only if FLAG_SAME_VALUE_LENGTH is not set in flag) - 1-5 bytes: prefix length - ... bytes: rest of the row (if prefix length is small enough) - ... bytes: qualifier (or suffix depending on prefix length) - 1-8 bytes: timestamp or diff - 1 byte: type (only if FLAG_SAME_TYPE is not set in the flag) - ... bytes: value

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.BufferedEncodedSeeker<STATE extends org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.SeekerState>
protected static class	org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.ClonedSeekerState Copies only the key part of the keybuffer by doing a deep copy and passes the seeker state members for taking a clone.
protected static class	org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.SeekerState
protected static class	DiffKeyDeltaEncoder.DiffCompressionState
protected static class	DiffKeyDeltaEncoder.DiffSeekerState

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.io.encoding.DataBlockEncoder

DataBlockEncoder.EncodedSeeker

Constructor Summary

Constructors

Constructor and Description
DiffKeyDeltaEncoder()

Method Summary

Modifier and Type	Method and Description
protected void	afterDecodingKeyValue(java.io.DataInputStream source, java.nio.ByteBuffer dest, HFileBlockDefaultDecodingContext decodingCtx)
protected int	afterEncodingKeyValue(Cell cell, java.io.DataOutputStream out, HFileBlockDefaultEncodingContext encodingCtx)
DataBlockEncoder.EncodedSeeker	createSeeker(KeyValue.KVComparator comparator, HFileBlockDecodingContext decodingCtx) Create a HFileBlock seeker which find KeyValues within a block.
java.nio.ByteBuffer	decodeKeyValues(java.io.DataInputStream source, HFileBlockDecodingContext blkDecodingCtx) Decode.
int	encode(Cell cell, HFileBlockEncodingContext encodingCtx, java.io.DataOutputStream out) Encodes a KeyValue.
void	endBlockEncoding(HFileBlockEncodingContext encodingCtx, java.io.DataOutputStream out, byte[] uncompressedBytesWithHeader) Ends encoding for a block of KeyValues.
protected static void	ensureSpace(java.nio.ByteBuffer out, int length) Asserts that there is at least the given amount of unfilled space remaining in the given buffer.
java.nio.ByteBuffer	getFirstKeyInBlock(java.nio.ByteBuffer block) Return first key in block.
protected java.nio.ByteBuffer	internalDecodeKeyValues(java.io.DataInputStream source, int allocateHeaderLength, int skipLastBytes, HFileBlockDefaultDecodingContext decodingCtx)
int	internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, java.io.DataOutputStream out)
HFileBlockDecodingContext	newDataBlockDecodingContext(HFileContext meta) Creates an encoder specific decoding context, which will prepare the data before actual decoding
HFileBlockEncodingContext	newDataBlockEncodingContext(DataBlockEncoding encoding, byte[] header, HFileContext meta) Creates a encoder specific encoding context
void	startBlockEncoding(HFileBlockEncodingContext blkEncodingCtx, java.io.DataOutputStream out) Starts encoding for a block of KeyValues.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

DiffKeyDeltaEncoder

public DiffKeyDeltaEncoder()

Method Detail

internalEncode

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

Throws:

java.io.IOException

getFirstKeyInBlock

public java.nio.ByteBuffer getFirstKeyInBlock(java.nio.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 java.lang.String toString()

Overrides:

toString in class java.lang.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 java.nio.ByteBuffer internalDecodeKeyValues(java.io.DataInputStream source,
                                                      int allocateHeaderLength,
                                                      int skipLastBytes,
                                                      HFileBlockDefaultDecodingContext decodingCtx)
                                               throws java.io.IOException

Throws:

java.io.IOException

decodeKeyValues

public java.nio.ByteBuffer decodeKeyValues(java.io.DataInputStream source,
                                           HFileBlockDecodingContext blkDecodingCtx)
                                    throws java.io.IOException

Description copied from interface: DataBlockEncoder

Decode.

Specified by:

decodeKeyValues in interface DataBlockEncoder

Parameters:

source - Compressed stream of KeyValues.

Returns:

Uncompressed block of KeyValues.

Throws:

java.io.IOException - If there is an error in source.

afterEncodingKeyValue

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

Parameters:

cell -

out -

encodingCtx -

Returns:

unencoded size added

Throws:

java.io.IOException

afterDecodingKeyValue

protected final void afterDecodingKeyValue(java.io.DataInputStream source,
                                           java.nio.ByteBuffer dest,
                                           HFileBlockDefaultDecodingContext decodingCtx)
                                    throws java.io.IOException

Throws:

java.io.IOException

newDataBlockEncodingContext

public HFileBlockEncodingContext newDataBlockEncodingContext(DataBlockEncoding encoding,
                                                             byte[] header,
                                                             HFileContext meta)

Description copied from interface: DataBlockEncoder

Creates a encoder specific encoding context

Specified by:

newDataBlockEncodingContext in interface DataBlockEncoder

Parameters:

encoding - encoding strategy used

header - header bytes to be written, put a dummy header here if the header is unknown

meta - HFile meta data

Returns:

a newly created encoding context

newDataBlockDecodingContext

public HFileBlockDecodingContext newDataBlockDecodingContext(HFileContext meta)

Description copied from interface: DataBlockEncoder

Creates an encoder specific decoding context, which will prepare the data before actual decoding

Specified by:

newDataBlockDecodingContext in interface DataBlockEncoder

Parameters:

meta - HFile meta data

Returns:

a newly created decoding context

ensureSpace

protected static void ensureSpace(java.nio.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.

startBlockEncoding

public void startBlockEncoding(HFileBlockEncodingContext blkEncodingCtx,
                               java.io.DataOutputStream out)
                        throws java.io.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:

java.io.IOException

encode

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

Description copied from interface: DataBlockEncoder

Encodes a KeyValue.

Specified by:

encode in interface DataBlockEncoder

Returns:

unencoded kv size written

Throws:

java.io.IOException

endBlockEncoding

public void endBlockEncoding(HFileBlockEncodingContext encodingCtx,
                             java.io.DataOutputStream out,
                             byte[] uncompressedBytesWithHeader)
                      throws java.io.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.

Specified by:

endBlockEncoding in interface DataBlockEncoder

Throws:

java.io.IOException