protected static class BufferedDataBlockEncoder.SeekerState extends Object
Modifier and Type | Field and Description |
---|---|
protected ByteBuff |
currentBuffer |
protected KeyValue.KeyOnlyKeyValue |
currentKey |
private 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 ObjectIntPair<ByteBuffer> |
tmpPair |
protected boolean |
uncompressTags |
protected int |
valueLength |
protected int |
valueOffset |
Constructor and Description |
---|
SeekerState(ObjectIntPair<ByteBuffer> tmpPair,
boolean includeTags) |
Modifier and Type | Method and 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) |
protected ByteBuff currentBuffer
protected TagCompressionContext tagCompressionContext
protected int valueOffset
protected int keyLength
protected int valueLength
protected int lastCommonPrefix
protected int tagsLength
protected int tagsOffset
protected int tagsCompressedLength
protected boolean uncompressTags
protected byte[] keyBuffer
protected byte[] tagsBuffer
protected long memstoreTS
protected int nextKvOffset
protected KeyValue.KeyOnlyKeyValue currentKey
private final ObjectIntPair<ByteBuffer> tmpPair
private final boolean includeTags
public SeekerState(ObjectIntPair<ByteBuffer> tmpPair, boolean includeTags)
protected boolean isValid()
protected void invalidate()
protected void ensureSpaceForKey()
protected void ensureSpaceForTags()
protected void setKey(byte[] keyBuffer, long memTS)
protected void copyFromNext(BufferedDataBlockEncoder.SeekerState nextState)
private Cell toOnheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize)
private Cell toOffheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.