@InterfaceAudience.Private public class MapReduceExtendedCell extends ByteBufferExtendedCell
| Modifier and Type | Field and Description |
|---|---|
private Cell |
cell |
CELL_NOT_BASED_ON_CHUNKMAX_TAGS_LENGTH| Constructor and Description |
|---|
MapReduceExtendedCell(Cell cell) |
| Modifier and Type | Method and Description |
|---|---|
ExtendedCell |
deepClone()
Does a deep copy of the contents to a new memory area and returns it as a new cell.
|
byte[] |
getFamilyArray()
Contiguous bytes composed of legal HDFS filename characters which may start at any index in the
containing array.
|
ByteBuffer |
getFamilyByteBuffer()
Returns The
ByteBuffer containing the column family bytes. |
byte |
getFamilyLength()
Returns Number of family bytes.
|
int |
getFamilyOffset()
Returns Array index of first family byte
|
int |
getFamilyPosition()
Returns Position in the
ByteBuffer where column family bytes start |
byte[] |
getQualifierArray()
Contiguous raw bytes that may start at any index in the containing array.
|
ByteBuffer |
getQualifierByteBuffer()
Returns The
ByteBuffer containing the column qualifier bytes. |
int |
getQualifierLength()
Returns Number of qualifier bytes.
|
int |
getQualifierOffset()
Returns Array index of first qualifier byte
|
int |
getQualifierPosition()
Returns Position in the
ByteBuffer where column qualifier bytes start |
byte[] |
getRowArray()
Contiguous raw bytes that may start at any index in the containing array.
|
ByteBuffer |
getRowByteBuffer()
Returns The
ByteBuffer containing the row bytes. |
short |
getRowLength()
Returns Number of row bytes.
|
int |
getRowOffset()
Returns Array index of first row byte
|
int |
getRowPosition()
Returns Position in the
ByteBuffer where row bytes start |
long |
getSequenceId()
A region-specific unique monotonically increasing sequence ID given to each Cell.
|
int |
getSerializedSize(boolean withTags)
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> |
byte[] |
getTagsArray()
Contiguous raw bytes representing tags that may start at any index in the containing array.
|
ByteBuffer |
getTagsByteBuffer()
Returns The
ByteBuffer containing the tag bytes. |
int |
getTagsLength()
HBase internally uses 2 bytes to store tags length in Cell.
|
int |
getTagsOffset()
Returns the first offset where the tags start in the Cell
|
int |
getTagsPosition()
Returns Position in the
ByteBuffer where tag bytes start |
long |
getTimestamp()
Return a long value representing time at which this cell was "Put" into the row.
|
byte |
getTypeByte()
Returns The byte representation of the KeyValue.TYPE of this cell: one of Put, Delete, etc
|
byte[] |
getValueArray()
Contiguous raw bytes that may start at any index in the containing array.
|
ByteBuffer |
getValueByteBuffer()
Returns The
ByteBuffer containing the value bytes. |
int |
getValueLength()
Returns Number of value bytes.
|
int |
getValueOffset()
Returns Array index of first value byte
|
int |
getValuePosition()
Returns Position in the
ByteBuffer where value bytes start |
long |
heapSize()
Return the approximate 'exclusive deep size' of implementing object.
|
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.
|
String |
toString() |
void |
write(ByteBuffer buf,
int offset)
Write this Cell into the given buf's offset in a
KeyValue format. |
int |
write(OutputStream out,
boolean withTags)
Write this cell to an OutputStream in a
KeyValue format. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetChunkId, getSerializedSizecheckForTagsLength, cloneTags, createCell, getTag, getTagspublic MapReduceExtendedCell(Cell cell)
public byte[] getRowArray()
Cellpublic int getRowOffset()
Cellpublic short getRowLength()
Cellpublic byte[] getFamilyArray()
Cellpublic int getFamilyOffset()
Cellpublic byte getFamilyLength()
Cellpublic byte[] getQualifierArray()
Cellpublic int getQualifierOffset()
Cellpublic int getQualifierLength()
Cellpublic long getTimestamp()
Cellpublic byte getTypeByte()
ExtendedCellpublic long getSequenceId()
ExtendedCellHConstants.KEEP_SEQID_PERIOD days, but generally becomes irrelevant after the cell's
row is no longer involved in any operations that require strict consistency.public byte[] getValueArray()
Cellpublic int getValueOffset()
Cellpublic int getValueLength()
Cellpublic byte[] getTagsArray()
ExtendedCellpublic int getTagsOffset()
ExtendedCellpublic int getTagsLength()
ExtendedCellpublic ByteBuffer getRowByteBuffer()
ByteBufferExtendedCellByteBuffer containing the row bytes.getRowByteBuffer in class ByteBufferExtendedCellpublic int getRowPosition()
ByteBufferExtendedCellByteBuffer where row bytes startgetRowPosition in class ByteBufferExtendedCellpublic ByteBuffer getFamilyByteBuffer()
ByteBufferExtendedCellByteBuffer containing the column family bytes.getFamilyByteBuffer in class ByteBufferExtendedCellpublic int getFamilyPosition()
ByteBufferExtendedCellByteBuffer where column family bytes startgetFamilyPosition in class ByteBufferExtendedCellpublic ByteBuffer getQualifierByteBuffer()
ByteBufferExtendedCellByteBuffer containing the column qualifier bytes.getQualifierByteBuffer in class ByteBufferExtendedCellpublic int getQualifierPosition()
ByteBufferExtendedCellByteBuffer where column qualifier bytes startgetQualifierPosition in class ByteBufferExtendedCellpublic ByteBuffer getValueByteBuffer()
ByteBufferExtendedCellByteBuffer containing the value bytes.getValueByteBuffer in class ByteBufferExtendedCellpublic int getValuePosition()
ByteBufferExtendedCellByteBuffer where value bytes startgetValuePosition in class ByteBufferExtendedCellpublic ByteBuffer getTagsByteBuffer()
ByteBufferExtendedCellByteBuffer containing the tag bytes.getTagsByteBuffer in class ByteBufferExtendedCellpublic int getTagsPosition()
ByteBufferExtendedCellByteBuffer where tag bytes startgetTagsPosition in class ByteBufferExtendedCellpublic void setSequenceId(long seqId) throws IOException
ExtendedCellseqId - sequence IDIOExceptionpublic void setTimestamp(long ts) throws IOException
ExtendedCellts - timestampIOExceptionpublic void setTimestamp(byte[] ts) throws IOException
ExtendedCellts - buffer containing the timestamp valueIOExceptionpublic long heapSize()
HeapSizepublic int write(OutputStream out, boolean withTags) throws IOException
ExtendedCellKeyValue 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>out - Stream to which cell has to be writtenwithTags - Whether to write tags.IOExceptionpublic int getSerializedSize(boolean withTags)
ExtendedCell<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>withTags - Whether to write tags.KeyValue format.public void write(ByteBuffer buf, int offset)
ExtendedCellKeyValue format.buf - The buffer where to write the Cell.offset - The offset within buffer, to write the Cell.public ExtendedCell deepClone()
ExtendedCellCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.