Package org.apache.hadoop.hbase.io.encoding

Class BufferedDataBlockEncoder.SeekerState

java.lang.Object

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

Direct Known Subclasses:

DiffKeyDeltaEncoder.DiffSeekerState, FastDiffDeltaEncoder.FastDiffSeekerState

Enclosing class:

BufferedDataBlockEncoder

protected static class BufferedDataBlockEncoder.SeekerState
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuff	currentBuffer
protected KeyValue.KeyOnlyKeyValue	currentKey
private final boolean	includeTags
protected byte[]	keyBuffer	We need to store a copy of the key.
protected int	keyLength
protected int	lastCommonPrefix
protected long	memstoreTS
protected int	nextKvOffset
protected TagCompressionContext	tagCompressionContext
protected byte[]	tagsBuffer
protected int	tagsCompressedLength
protected int	tagsLength
protected int	tagsOffset
private final ObjectIntPair<ByteBuffer>	tmpPair
protected boolean	uncompressTags
protected int	valueLength
protected int	valueOffset

Constructor Summary

Constructors

Constructor	Description
SeekerState(ObjectIntPair<ByteBuffer> tmpPair, boolean includeTags)

Method Summary

Modifier and Type	Method	Description
protected void	copyFromNext(BufferedDataBlockEncoder.SeekerState nextState)	Copy the state from the next one into this instance (the previous state placeholder).
protected void	ensureSpaceForKey()
protected void	ensureSpaceForTags()
protected void	invalidate()
protected boolean	isValid()
protected void	setKey(byte[] keyBuffer, long memTS)
Cell	toCell()
private Cell	toOffheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize)
private Cell	toOnheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize)

Methods inherited from class java.lang.Object

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

Field Details

currentBuffer

protected ByteBuff currentBuffer

tagCompressionContext

protected TagCompressionContext tagCompressionContext

valueOffset

protected int valueOffset

keyLength

protected int keyLength

valueLength

protected int valueLength

lastCommonPrefix

protected int lastCommonPrefix

tagsLength

protected int tagsLength

tagsOffset

protected int tagsOffset

tagsCompressedLength

protected int tagsCompressedLength

uncompressTags

protected boolean uncompressTags

keyBuffer

protected byte[] keyBuffer

We need to store a copy of the key.

tagsBuffer

protected byte[] tagsBuffer

memstoreTS

protected long memstoreTS

nextKvOffset

protected int nextKvOffset

currentKey

protected KeyValue.KeyOnlyKeyValue currentKey

tmpPair

private final ObjectIntPair<ByteBuffer> tmpPair

includeTags

private final boolean includeTags

Constructor Details

SeekerState

public SeekerState(ObjectIntPair<ByteBuffer> tmpPair,
 boolean includeTags)

Method Details

isValid

protected boolean isValid()

invalidate

protected void invalidate()

ensureSpaceForKey

protected void ensureSpaceForKey()

ensureSpaceForTags

protected void ensureSpaceForTags()

setKey

protected void setKey(byte[] keyBuffer,
 long memTS)

copyFromNext

protected void copyFromNext(BufferedDataBlockEncoder.SeekerState nextState)

Copy the state from the next one into this instance (the previous state placeholder). Used to save the previous state when we are advancing the seeker to the next key/value.

toCell

public Cell toCell()

toOnheapCell

private Cell toOnheapCell(ByteBuffer valAndTagsBuffer,
 int vOffset,
 int tagsLenSerializationSize)

toOffheapCell

private Cell toOffheapCell(ByteBuffer valAndTagsBuffer,
 int vOffset,
 int tagsLenSerializationSize)