org.apache.hadoop.hbase.io.encoding

Class BufferedDataBlockEncoder.BufferedEncodedSeeker<STATE extends BufferedDataBlockEncoder.SeekerState>

java.lang.Object

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

org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.BufferedEncodedSeeker<STATE>

All Implemented Interfaces:

DataBlockEncoder.EncodedSeeker

Enclosing class:

BufferedDataBlockEncoder

protected abstract static class BufferedDataBlockEncoder.BufferedEncodedSeeker<STATE extends BufferedDataBlockEncoder.SeekerState>
extends AbstractDataBlockEncoder.AbstractEncodedSeeker

Field Summary

Fields

Modifier and Type	Field and Description
protected STATE	current
protected ByteBuff	currentBuffer
protected KeyValue.KeyOnlyKeyValue	keyOnlyKV
protected STATE	previous
protected TagCompressionContext	tagCompressionContext
protected ObjectIntPair<ByteBuffer>	tmpPair

Fields inherited from class org.apache.hadoop.hbase.io.encoding.AbstractDataBlockEncoder.AbstractEncodedSeeker

comparator, decodingCtx

Constructor Summary

Constructors

Constructor and Description
BufferedEncodedSeeker(CellComparator comparator, HFileBlockDecodingContext decodingCtx)

Method Summary

Modifier and Type	Method and Description
int	compareKey(CellComparator comparator, Cell key) Compare the given key against the current key
private int	compareTypeBytes(Cell key, Cell right)
protected STATE	createSeekerState()
protected abstract void	decodeFirst()
protected abstract void	decodeNext()
protected void	decodeTags()
private static int	findCommonPrefixInFamilyPart(Cell left, Cell right, int familyCommonPrefix)
private static int	findCommonPrefixInQualifierPart(Cell left, Cell right, int qualifierCommonPrefix)
private static int	findCommonPrefixInRowPart(Cell left, Cell right, int rowCommonPrefix)
Cell	getCell()
Cell	getKey() From the current position creates a cell using the key part of the current buffer
ByteBuffer	getValueShallowCopy() Does a shallow copy of the value at the current position.
private void	moveToPrevious()
boolean	next() Move to next position
void	rewind() Set position to beginning of given block
int	seekToKeyInBlock(Cell seekCell, boolean seekBefore) Moves the seeker position within the current block to: the last key that that is less than or equal to the given key if seekBefore is false the last key that is strictly less than the given key if seekBefore is true.
void	setCurrentBuffer(ByteBuff buffer) Set on which buffer there will be done seeking.

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

includesMvcc, includesTags

Methods inherited from class java.lang.Object

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

Field Detail

currentBuffer

protected ByteBuff currentBuffer

tagCompressionContext

protected TagCompressionContext tagCompressionContext

keyOnlyKV

protected KeyValue.KeyOnlyKeyValue keyOnlyKV

tmpPair

protected final ObjectIntPair<ByteBuffer> tmpPair

current

protected STATE extends BufferedDataBlockEncoder.SeekerState current

previous

protected STATE extends BufferedDataBlockEncoder.SeekerState previous

Constructor Detail

BufferedEncodedSeeker

public BufferedEncodedSeeker(CellComparator comparator,
                             HFileBlockDecodingContext decodingCtx)

Method Detail

compareKey

public int compareKey(CellComparator comparator,
                      Cell key)

Description copied from interface: DataBlockEncoder.EncodedSeeker

Compare the given key against the current key

Returns:

-1 is the passed key is smaller than the current key, 0 if equal and 1 if greater

setCurrentBuffer

public void setCurrentBuffer(ByteBuff buffer)

Description copied from interface: DataBlockEncoder.EncodedSeeker

Set on which buffer there will be done seeking.

Parameters:

buffer - Used for seeking.

getKey

public Cell getKey()

Description copied from interface: DataBlockEncoder.EncodedSeeker

From the current position creates a cell using the key part of the current buffer

Returns:

key at current position

getValueShallowCopy

public ByteBuffer getValueShallowCopy()

Description copied from interface: DataBlockEncoder.EncodedSeeker

Does a shallow copy of the value at the current position. A shallow copy is possible because the returned buffer refers to the backing array of the original encoded buffer.

Returns:

value at current position

getCell

public Cell getCell()

Returns:

the Cell at the current position. Includes memstore timestamp.

rewind

public void rewind()

Description copied from interface: DataBlockEncoder.EncodedSeeker

Set position to beginning of given block

next

public boolean next()

Description copied from interface: DataBlockEncoder.EncodedSeeker

Move to next position

Returns:

true on success, false if there is no more positions.

decodeTags

protected void decodeTags()

seekToKeyInBlock

public int seekToKeyInBlock(Cell seekCell,
                            boolean seekBefore)

Description copied from interface: DataBlockEncoder.EncodedSeeker

Moves the seeker position within the current block to:

• the last key that that is less than or equal to the given key if seekBefore is false
• the last key that is strictly less than the given key if seekBefore is true. The caller is responsible for loading the previous block if the requested key turns out to be the first key of the current block.

Parameters:

seekCell - - Cell to which the seek should happen

seekBefore - find the key strictly less than the given key in case of an exact match. Does not matter in case of an inexact match.

Returns:

0 on exact match, 1 on inexact match.

compareTypeBytes

private int compareTypeBytes(Cell key,
                             Cell right)

findCommonPrefixInRowPart

private static int findCommonPrefixInRowPart(Cell left,
                                             Cell right,
                                             int rowCommonPrefix)

findCommonPrefixInFamilyPart

private static int findCommonPrefixInFamilyPart(Cell left,
                                                Cell right,
                                                int familyCommonPrefix)

findCommonPrefixInQualifierPart

private static int findCommonPrefixInQualifierPart(Cell left,
                                                   Cell right,
                                                   int qualifierCommonPrefix)

moveToPrevious

private void moveToPrevious()

createSeekerState

protected STATE createSeekerState()

decodeFirst

protected abstract void decodeFirst()

decodeNext

protected abstract void decodeNext()