org.apache.hadoop.hbase.io.encoding

Class CopyKeyDataBlockEncoder

java.lang.Object

org.apache.hadoop.hbase.io.encoding.AbstractDataBlockEncoder

org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder

org.apache.hadoop.hbase.io.encoding.CopyKeyDataBlockEncoder

All Implemented Interfaces:

DataBlockEncoder

@InterfaceAudience.Private
public class CopyKeyDataBlockEncoder
extends BufferedDataBlockEncoder

Just copy data, do not do any kind of compression. Use for comparison and benchmarking.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	CopyKeyDataBlockEncoder.CopyKeyEncodingState

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder

BufferedDataBlockEncoder.BufferedEncodedSeeker<STATE extends BufferedDataBlockEncoder.SeekerState>, BufferedDataBlockEncoder.OffheapDecodedExtendedCell, BufferedDataBlockEncoder.OnheapDecodedCell, BufferedDataBlockEncoder.SeekerState

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.io.encoding.AbstractDataBlockEncoder

AbstractDataBlockEncoder.AbstractEncodedSeeker

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

DataBlockEncoder.EncodedSeeker

Constructor Summary

Constructors

Constructor and Description
CopyKeyDataBlockEncoder()

Method Summary

Modifier and Type	Method and Description
DataBlockEncoder.EncodedSeeker	createSeeker(CellComparator comparator, HFileBlockDecodingContext decodingCtx) Create a HFileBlock seeker which find KeyValues within a block.
Cell	getFirstKeyCellInBlock(ByteBuff block) Return first key in block as a cell.
protected ByteBuffer	internalDecodeKeyValues(DataInputStream source, int allocateHeaderLength, int skipLastBytes, HFileBlockDefaultDecodingContext decodingCtx)
int	internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, DataOutputStream out)
void	startBlockEncoding(HFileBlockEncodingContext blkEncodingCtx, DataOutputStream out) Starts encoding for a block of KeyValues.
String	toString()

Methods inherited from class org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder

afterDecodingKeyValue, afterEncodingKeyValue, compareCommonFamilyPrefix, compareCommonQualifierPrefix, compareCommonRowPrefix, decodeKeyValues, encode, endBlockEncoding, ensureSpace

Methods inherited from class org.apache.hadoop.hbase.io.encoding.AbstractDataBlockEncoder

createFirstKeyCell, newDataBlockDecodingContext, newDataBlockEncodingContext, postEncoding

Methods inherited from class java.lang.Object

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

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

Overrides:

startBlockEncoding in class BufferedDataBlockEncoder

Throws:

IOException

internalEncode

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

Specified by:

internalEncode in class BufferedDataBlockEncoder

Throws:

IOException

getFirstKeyCellInBlock

public Cell getFirstKeyCellInBlock(ByteBuff block)

Description copied from interface: DataBlockEncoder

Return first key in block as a cell. 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 as a cell.

toString

public String toString()

Overrides:

toString in class Object

createSeeker

public DataBlockEncoder.EncodedSeeker createSeeker(CellComparator 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

Specified by:

internalDecodeKeyValues in class BufferedDataBlockEncoder

Throws:

IOException