org.apache.hadoop.hbase.io.encoding

Class RowIndexSeekerV1

java.lang.Object

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

org.apache.hadoop.hbase.io.encoding.RowIndexSeekerV1

All Implemented Interfaces:

DataBlockEncoder.EncodedSeeker

@InterfaceAudience.Private
public class RowIndexSeekerV1
extends AbstractDataBlockEncoder.AbstractEncodedSeeker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	RowIndexSeekerV1.SeekerState

Field Summary

Fields

Modifier and Type	Field and Description
private RowIndexSeekerV1.SeekerState	current
private ByteBuff	currentBuffer
private RowIndexSeekerV1.SeekerState	previous
private int	rowNumber
private ByteBuff	rowOffsets
protected ObjectIntPair<ByteBuffer>	tmpPair

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

comparator, decodingCtx

Constructor Summary

Constructors

Constructor and Description
RowIndexSeekerV1(CellComparator comparator, HFileBlockDecodingContext decodingCtx)

Method Summary

Modifier and Type	Method and Description
private int	binarySearch(Cell seekCell, boolean seekBefore)
int	compareKey(CellComparator comparator, Cell key) Compare the given key against the current key
private int	compareRows(ByteBuffer row, Cell seekCell)
protected void	decodeAtPosition(int position)
protected void	decodeFirst()
protected void	decodeNext()
protected void	decodeTags()
Cell	getCell()
Cell	getKey() From the current position creates a cell using the key part of the current buffer
private ByteBuffer	getRow(int index)
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

tmpPair

protected final ObjectIntPair<ByteBuffer> tmpPair

currentBuffer

private ByteBuff currentBuffer

current

private RowIndexSeekerV1.SeekerState current

previous

private RowIndexSeekerV1.SeekerState previous

rowNumber

private int rowNumber

rowOffsets

private ByteBuff rowOffsets

Constructor Detail

RowIndexSeekerV1

public RowIndexSeekerV1(CellComparator comparator,
                        HFileBlockDecodingContext decodingCtx)

Method Detail

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.

binarySearch

private int binarySearch(Cell seekCell,
                         boolean seekBefore)

compareRows

private int compareRows(ByteBuffer row,
                        Cell seekCell)

getRow

private ByteBuffer getRow(int index)

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.

moveToPrevious

private void moveToPrevious()

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

decodeFirst

protected void decodeFirst()

decodeAtPosition

protected void decodeAtPosition(int position)

decodeNext

protected void decodeNext()

decodeTags

protected void decodeTags()