org.apache.hadoop.hbase

Interface ExtendedCell

All Superinterfaces:

Cell, HeapSize, RawCell

All Known Implementing Classes:

BufferedDataBlockEncoder.OffheapDecodedExtendedCell, BufferedDataBlockEncoder.OnheapDecodedCell, ByteBufferChunkKeyValue, ByteBufferExtendedCell, ByteBufferKeyOnlyKeyValue, ByteBufferKeyValue, IndividualBytesFieldCell, KeyOnlyFilter.KeyOnlyByteBufferExtendedCell, KeyValue, KeyValue.KeyOnlyKeyValue, MapReduceExtendedCell, Mutation.CellWrapper, NoTagByteBufferChunkKeyValue, NoTagsByteBufferKeyValue, NoTagsKeyValue, PrivateCellUtil.EmptyByteBufferExtendedCell, PrivateCellUtil.EmptyCell, PrivateCellUtil.FirstOnRowByteBufferExtendedCell, PrivateCellUtil.FirstOnRowCell, PrivateCellUtil.FirstOnRowColByteBufferExtendedCell, PrivateCellUtil.FirstOnRowColCell, PrivateCellUtil.FirstOnRowColTSByteBufferExtendedCell, PrivateCellUtil.FirstOnRowColTSCell, PrivateCellUtil.FirstOnRowDeleteFamilyCell, PrivateCellUtil.LastOnRowByteBufferExtendedCell, PrivateCellUtil.LastOnRowCell, PrivateCellUtil.LastOnRowColByteBufferExtendedCell, PrivateCellUtil.LastOnRowColCell, PrivateCellUtil.TagRewriteByteBufferExtendedCell, PrivateCellUtil.TagRewriteCell, PrivateCellUtil.ValueAndTagRewriteByteBufferExtendedCell, PrivateCellUtil.ValueAndTagRewriteCell, SizeCachedKeyValue, SizeCachedNoTagsKeyValue

@InterfaceAudience.Private
public interface ExtendedCell
extends RawCell, HeapSize

Extension to Cell with server side required functions. Server side Cell implementations must implement this.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Cell

Cell.Type

Field Summary

Fields

Modifier and Type	Field and Description
static int	CELL_NOT_BASED_ON_CHUNK

Fields inherited from interface org.apache.hadoop.hbase.RawCell

MAX_TAGS_LENGTH

Method Summary

Modifier and Type	Method and Description
default ExtendedCell	deepClone() Does a deep copy of the contents to a new memory area and returns it as a new cell.
default int	getChunkId() Extracts the id of the backing bytebuffer of this cell if it was obtained from fixed sized chunks as in case of MemstoreLAB
long	getSequenceId() A region-specific unique monotonically increasing sequence ID given to each Cell.
default int	getSerializedSize()
default int	getSerializedSize(boolean withTags)
byte[]	getTagsArray() Contiguous raw bytes representing tags that may start at any index in the containing array.
int	getTagsLength() HBase internally uses 2 bytes to store tags length in Cell.
int	getTagsOffset()
byte	getTypeByte()
void	setSequenceId(long seqId) Sets with the given seqId.
void	setTimestamp(byte[] ts) Sets with the given timestamp.
void	setTimestamp(long ts) Sets with the given timestamp.
default void	write(ByteBuffer buf, int offset) Write this Cell into the given buf's offset in a KeyValue format.
default int	write(OutputStream out, boolean withTags) Write this cell to an OutputStream in a KeyValue format.

Methods inherited from interface org.apache.hadoop.hbase.RawCell

checkForTagsLength, cloneTags, getTag, getTags

Methods inherited from interface org.apache.hadoop.hbase.Cell

getFamilyArray, getFamilyLength, getFamilyOffset, getQualifierArray, getQualifierLength, getQualifierOffset, getRowArray, getRowLength, getRowOffset, getTimestamp, getType, getValueArray, getValueLength, getValueOffset

Methods inherited from interface org.apache.hadoop.hbase.io.HeapSize

heapSize

Field Detail

CELL_NOT_BASED_ON_CHUNK

static final int CELL_NOT_BASED_ON_CHUNK

See Also:

Constant Field Values

Method Detail

write

default int write(OutputStream out,
                  boolean withTags)
           throws IOException

Write this cell to an OutputStream in a KeyValue format.
KeyValue format
<4 bytes keylength> <4 bytes valuelength> <2 bytes rowlength> <row> <1 byte columnfamilylength> <columnfamily> <columnqualifier> <8 bytes timestamp> <1 byte keytype> <value> <2 bytes tagslength> <tags>

Parameters:

out - Stream to which cell has to be written

withTags - Whether to write tags.

Returns:

how many bytes are written.

Throws:

IOException

getSerializedSize

default int getSerializedSize(boolean withTags)

Parameters:

withTags - Whether to write tags.

Returns:

Bytes count required to serialize this Cell in a KeyValue format.
KeyValue format
<4 bytes keylength> <4 bytes valuelength> <2 bytes rowlength> <row> <1 byte columnfamilylength> <columnfamily> <columnqualifier> <8 bytes timestamp> <1 byte keytype> <value> <2 bytes tagslength> <tags>

getSerializedSize

default int getSerializedSize()

Specified by:

getSerializedSize in interface Cell

Returns:

Serialized size (defaults to include tag length).

write

default void write(ByteBuffer buf,
                   int offset)

Write this Cell into the given buf's offset in a KeyValue format.

Parameters:

buf - The buffer where to write the Cell.

offset - The offset within buffer, to write the Cell.

deepClone

default ExtendedCell deepClone()

Does a deep copy of the contents to a new memory area and returns it as a new cell.

Returns:

The deep cloned cell

getChunkId

default int getChunkId()

Extracts the id of the backing bytebuffer of this cell if it was obtained from fixed sized chunks as in case of MemstoreLAB

Returns:

the chunk id if the cell is backed by fixed sized Chunks, else return CELL_NOT_BASED_ON_CHUNK; i.e. -1.

setSequenceId

void setSequenceId(long seqId)
            throws IOException

Sets with the given seqId.

Parameters:

seqId - sequence ID

Throws:

IOException

setTimestamp

void setTimestamp(long ts)
           throws IOException

Sets with the given timestamp.

Parameters:

ts - timestamp

Throws:

IOException

setTimestamp

void setTimestamp(byte[] ts)
           throws IOException

Sets with the given timestamp.

Parameters:

ts - buffer containing the timestamp value

Throws:

IOException

getSequenceId

long getSequenceId()

A region-specific unique monotonically increasing sequence ID given to each Cell. It always exists for cells in the memstore but is not retained forever. It will be kept for HConstants.KEEP_SEQID_PERIOD days, but generally becomes irrelevant after the cell's row is no longer involved in any operations that require strict consistency.

Specified by:

getSequenceId in interface Cell

Returns:

seqId (always > 0 if exists), or 0 if it no longer exists

getTagsArray

byte[] getTagsArray()

Contiguous raw bytes representing tags that may start at any index in the containing array.

Specified by:

getTagsArray in interface Cell

Returns:

the tags byte array

getTagsOffset

int getTagsOffset()

Specified by:

getTagsOffset in interface Cell

Returns:

the first offset where the tags start in the Cell

getTagsLength

int getTagsLength()

HBase internally uses 2 bytes to store tags length in Cell. As the tags length is always a non-negative number, to make good use of the sign bit, the max of tags length is defined 2 * Short.MAX_VALUE + 1 = 65535. As a result, the return type is int, because a short is not capable of handling that. Please note that even if the return type is int, the max tags length is far less than Integer.MAX_VALUE.

Specified by:

getTagsLength in interface Cell

Returns:

the total length of the tags in the Cell.

getTypeByte

byte getTypeByte()

Specified by:

getTypeByte in interface Cell

Returns:

The byte representation of the KeyValue.TYPE of this cell: one of Put, Delete, etc