static class PrivateCellUtil.TagRewriteCell extends Object implements ExtendedCell
| Modifier and Type | Field and Description |
|---|---|
protected Cell |
cell |
private static int |
HEAP_SIZE_OVERHEAD |
protected byte[] |
tags |
CELL_NOT_BASED_ON_CHUNKMAX_TAGS_LENGTH| Constructor and Description |
|---|
TagRewriteCell(Cell cell,
byte[] tags)
Construct a TagRewriteCell
|
| 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.
|
byte |
getFamilyLength()
Returns Number of family bytes.
|
int |
getFamilyOffset()
Returns Array index of first family byte
|
byte[] |
getQualifierArray()
Contiguous raw bytes that may start at any index in the containing array.
|
int |
getQualifierLength()
Returns Number of qualifier bytes.
|
int |
getQualifierOffset()
Returns Array index of first qualifier byte
|
byte[] |
getRowArray()
Contiguous raw bytes that may start at any index in the containing array.
|
short |
getRowLength()
Returns Number of row bytes.
|
int |
getRowOffset()
Returns Array index of first row byte
|
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.
|
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
|
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.
|
int |
getValueLength()
Returns Number of value bytes.
|
int |
getValueOffset()
Returns Array index of first value byte
|
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.
|
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, toString, wait, wait, waitgetChunkId, getSerializedSizecheckForTagsLength, cloneTags, createCell, getTag, getTagsprotected byte[] tags
private static final int HEAP_SIZE_OVERHEAD
public TagRewriteCell(Cell cell, byte[] tags)
cell - The original Cell which it rewritestags - the tags bytes. The array suppose to contain the tags bytes alone.public byte[] getRowArray()
CellgetRowArray in interface Cellpublic int getRowOffset()
CellgetRowOffset in interface Cellpublic short getRowLength()
CellgetRowLength in interface Cellpublic byte[] getFamilyArray()
CellgetFamilyArray in interface Cellpublic int getFamilyOffset()
CellgetFamilyOffset in interface Cellpublic byte getFamilyLength()
CellgetFamilyLength in interface Cellpublic byte[] getQualifierArray()
CellgetQualifierArray in interface Cellpublic int getQualifierOffset()
CellgetQualifierOffset in interface Cellpublic int getQualifierLength()
CellgetQualifierLength in interface Cellpublic long getTimestamp()
CellgetTimestamp in interface Cellpublic byte getTypeByte()
ExtendedCellgetTypeByte in interface CellgetTypeByte in interface 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.getSequenceId in interface CellgetSequenceId in interface ExtendedCellpublic byte[] getValueArray()
CellgetValueArray in interface Cellpublic int getValueOffset()
CellgetValueOffset in interface Cellpublic int getValueLength()
CellgetValueLength in interface Cellpublic byte[] getTagsArray()
ExtendedCellgetTagsArray in interface CellgetTagsArray in interface ExtendedCellpublic int getTagsOffset()
ExtendedCellgetTagsOffset in interface CellgetTagsOffset in interface ExtendedCellpublic int getTagsLength()
ExtendedCellgetTagsLength in interface CellgetTagsLength in interface ExtendedCellpublic long heapSize()
HeapSizepublic void setTimestamp(long ts) throws IOException
ExtendedCellsetTimestamp in interface ExtendedCellts - timestampIOExceptionpublic void setTimestamp(byte[] ts) throws IOException
ExtendedCellsetTimestamp in interface ExtendedCellts - buffer containing the timestamp valueIOExceptionpublic void setSequenceId(long seqId) throws IOException
ExtendedCellsetSequenceId in interface ExtendedCellseqId - sequence IDIOExceptionpublic 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>write in interface ExtendedCellout - 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>getSerializedSize in interface ExtendedCellwithTags - Whether to write tags.KeyValue format.public void write(ByteBuffer buf, int offset)
ExtendedCellKeyValue format.write in interface ExtendedCellbuf - The buffer where to write the Cell.offset - The offset within buffer, to write the Cell.public ExtendedCell deepClone()
ExtendedCelldeepClone in interface ExtendedCellCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.