MapReduceExtendedCell (Apache HBase 2.2.3 API)

java.lang.Object
- org.apache.hadoop.hbase.ByteBufferExtendedCell
- - org.apache.hadoop.hbase.util.MapReduceExtendedCell

All Implemented Interfaces:

Cell, ExtendedCell, HeapSize, RawCell
```
@InterfaceAudience.Private
public class MapReduceExtendedCell
extends ByteBufferExtendedCell
```
A wrapper for a cell to be used with mapreduce, as the output value class for mappers/reducers.

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

private Cell cell
- Fields inherited from interface org.apache.hadoop.hbase.ExtendedCell
  CELL_NOT_BASED_ON_CHUNK
- Fields inherited from interface org.apache.hadoop.hbase.RawCell
  MAX_TAGS_LENGTH

Fields
Modifier and Type	Field and Description
`private Cell`	`cell`

Constructor Summary

Constructors
Constructor and Description

MapReduceExtendedCell(Cell cell)

Constructors
Constructor and Description
`MapReduceExtendedCell(Cell cell)`

Method Summary

All Methods Instance Methods Concrete Methods
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()`
`byte`	`getFamilyLength()`
`int`	`getFamilyOffset()`
`int`	`getFamilyPosition()`
`byte[]`	`getQualifierArray()` Contiguous raw bytes that may start at any index in the containing array.
`ByteBuffer`	`getQualifierByteBuffer()`
`int`	`getQualifierLength()`
`int`	`getQualifierOffset()`
`int`	`getQualifierPosition()`
`byte[]`	`getRowArray()` Contiguous raw bytes that may start at any index in the containing array.
`ByteBuffer`	`getRowByteBuffer()`
`short`	`getRowLength()`
`int`	`getRowOffset()`
`int`	`getRowPosition()`
`long`	`getSequenceId()` A region-specific unique monotonically increasing sequence ID given to each Cell.
`int`	`getSerializedSize(boolean withTags)`
`byte[]`	`getTagsArray()` Contiguous raw bytes representing tags that may start at any index in the containing array.
`ByteBuffer`	`getTagsByteBuffer()`
`int`	`getTagsLength()` HBase internally uses 2 bytes to store tags length in Cell.
`int`	`getTagsOffset()`
`int`	`getTagsPosition()`
`long`	`getTimestamp()`
`byte`	`getTypeByte()`
`byte[]`	`getValueArray()` Contiguous raw bytes that may start at any index in the containing array.
`ByteBuffer`	`getValueByteBuffer()`
`int`	`getValueLength()`
`int`	`getValueOffset()`
`int`	`getValuePosition()`
`long`	`heapSize()`
`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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.ExtendedCell
getChunkId, getSerializedSize

Methods inherited from interface org.apache.hadoop.hbase.RawCell
checkForTagsLength, cloneTags, getTag, getTags

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

- Field Detail
  - cell
```
private final Cell cell
```
- Constructor Detail
  - MapReduceExtendedCell
```
public MapReduceExtendedCell(Cell cell)
```
- Method Detail
  - getRowArray
```
public byte[] getRowArray()
```
    Description copied from interface: Cell
    
    Contiguous raw bytes that may start at any index in the containing array. Max length is Short.MAX_VALUE which is 32,767 bytes.
    
    Returns:
    
    The array containing the row bytes.
  - getRowOffset
```
public int getRowOffset()
```
    Returns:
    
    Array index of first row byte
  - getRowLength
```
public short getRowLength()
```
    Returns:
    
    Number of row bytes. Must be < rowArray.length - offset.
  - getFamilyArray
```
public byte[] getFamilyArray()
```
    Description copied from interface: Cell
    
    Contiguous bytes composed of legal HDFS filename characters which may start at any index in the containing array. Max length is Byte.MAX_VALUE, which is 127 bytes.
    
    Returns:
    
    the array containing the family bytes.
  - getFamilyOffset
```
public int getFamilyOffset()
```
    Returns:
    
    Array index of first family byte
  - getFamilyLength
```
public byte getFamilyLength()
```
    Returns:
    
    Number of family bytes. Must be < familyArray.length - offset.
  - getQualifierArray
```
public byte[] getQualifierArray()
```
    Description copied from interface: Cell
    
    Contiguous raw bytes that may start at any index in the containing array.
    
    Returns:
    
    The array containing the qualifier bytes.
  - getQualifierOffset
```
public int getQualifierOffset()
```
    Returns:
    
    Array index of first qualifier byte
  - getQualifierLength
```
public int getQualifierLength()
```
    Returns:
    
    Number of qualifier bytes. Must be < qualifierArray.length - offset.
  - getTimestamp
```
public long getTimestamp()
```
    Returns:
    
    Long value representing time at which this cell was "Put" into the row. Typically represents the time of insertion, but can be any value from 0 to Long.MAX_VALUE.
  - getTypeByte
```
public byte getTypeByte()
```
    Returns:
    
    The byte representation of the KeyValue.TYPE of this cell: one of Put, Delete, etc
  - getSequenceId
```
public long getSequenceId()
```
    Description copied from interface: ExtendedCell
    
    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.
    
    Returns:
    
    seqId (always > 0 if exists), or 0 if it no longer exists
  - getValueArray
```
public byte[] getValueArray()
```
    Description copied from interface: Cell
    
    Contiguous raw bytes that may start at any index in the containing array. Max length is Integer.MAX_VALUE which is 2,147,483,647 bytes.
    
    Returns:
    
    The array containing the value bytes.
  - getValueOffset
```
public int getValueOffset()
```
    Returns:
    
    Array index of first value byte
  - getValueLength
```
public int getValueLength()
```
    Returns:
    
    Number of value bytes. Must be < valueArray.length - offset.
  - getTagsArray
```
public byte[] getTagsArray()
```
    Description copied from interface: ExtendedCell
    
    Contiguous raw bytes representing tags that may start at any index in the containing array.
    
    Returns:
    
    the tags byte array
  - getTagsOffset
```
public int getTagsOffset()
```
    Returns:
    
    the first offset where the tags start in the Cell
  - getTagsLength
```
public int getTagsLength()
```
    Description copied from interface: ExtendedCell
    
    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.
    
    Returns:
    
    the total length of the tags in the Cell.
  - getRowByteBuffer
```
public ByteBuffer getRowByteBuffer()
```
    Specified by:
    
    getRowByteBuffer in class ByteBufferExtendedCell
    
    Returns:
    
    The ByteBuffer containing the row bytes.
  - getRowPosition
```
public int getRowPosition()
```
    Specified by:
    
    getRowPosition in class ByteBufferExtendedCell
    
    Returns:
    
    Position in the ByteBuffer where row bytes start
  - getFamilyByteBuffer
```
public ByteBuffer getFamilyByteBuffer()
```
    Specified by:
    
    getFamilyByteBuffer in class ByteBufferExtendedCell
    
    Returns:
    
    The ByteBuffer containing the column family bytes.
  - getFamilyPosition
```
public int getFamilyPosition()
```
    Specified by:
    
    getFamilyPosition in class ByteBufferExtendedCell
    
    Returns:
    
    Position in the ByteBuffer where column family bytes start
  - getQualifierByteBuffer
```
public ByteBuffer getQualifierByteBuffer()
```
    Specified by:
    
    getQualifierByteBuffer in class ByteBufferExtendedCell
    
    Returns:
    
    The ByteBuffer containing the column qualifier bytes.
  - getQualifierPosition
```
public int getQualifierPosition()
```
    Specified by:
    
    getQualifierPosition in class ByteBufferExtendedCell
    
    Returns:
    
    Position in the ByteBuffer where column qualifier bytes start
  - getValueByteBuffer
```
public ByteBuffer getValueByteBuffer()
```
    Specified by:
    
    getValueByteBuffer in class ByteBufferExtendedCell
    
    Returns:
    
    The ByteBuffer containing the value bytes.
  - getValuePosition
```
public int getValuePosition()
```
    Specified by:
    
    getValuePosition in class ByteBufferExtendedCell
    
    Returns:
    
    Position in the ByteBuffer where value bytes start
  - getTagsByteBuffer
```
public ByteBuffer getTagsByteBuffer()
```
    Specified by:
    
    getTagsByteBuffer in class ByteBufferExtendedCell
    
    Returns:
    
    The ByteBuffer containing the tag bytes.
  - getTagsPosition
```
public int getTagsPosition()
```
    Specified by:
    
    getTagsPosition in class ByteBufferExtendedCell
    
    Returns:
    
    Position in the ByteBuffer where tag bytes start
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - setSequenceId
```
public void setSequenceId(long seqId)
                   throws IOException
```
    Description copied from interface: ExtendedCell
    
    Sets with the given seqId.
    
    Parameters:
    
    seqId - sequence ID
    
    Throws:
    
    IOException
  - setTimestamp
```
public void setTimestamp(long ts)
                  throws IOException
```
    Description copied from interface: ExtendedCell
    
    Sets with the given timestamp.
    
    Parameters:
    
    ts - timestamp
    
    Throws:
    
    IOException
  - setTimestamp
```
public void setTimestamp(byte[] ts)
                  throws IOException
```
    Description copied from interface: ExtendedCell
    
    Sets with the given timestamp.
    
    Parameters:
    
    ts - buffer containing the timestamp value
    
    Throws:
    
    IOException
  - heapSize
```
public long heapSize()
```
    Returns:
    
    Approximate 'exclusive deep size' of implementing object. Includes count of payload and hosting object sizings.
  - write
```
public int write(OutputStream out,
                 boolean withTags)
          throws IOException
```
    Description copied from interface: ExtendedCell
    
    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
```
public 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>
  - write
```
public void write(ByteBuffer buf,
                  int offset)
```
    Description copied from interface: ExtendedCell
    
    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
```
public ExtendedCell deepClone()
```
    Description copied from interface: ExtendedCell
    
    Does a deep copy of the contents to a new memory area and returns it as a new cell.
    
    Returns:
    
    The deep cloned cell

Class MapReduceExtendedCell

Nested Class Summary

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

Field Summary

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

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

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

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

Field Detail

cell

Constructor Detail

MapReduceExtendedCell

Method Detail

getRowArray

getRowOffset

getRowLength

getFamilyArray

getFamilyOffset

getFamilyLength

getQualifierArray

getQualifierOffset

getQualifierLength

getTimestamp

getTypeByte

getSequenceId

getValueArray

getValueOffset

getValueLength

getTagsArray

getTagsOffset

getTagsLength

getRowByteBuffer

getRowPosition

getFamilyByteBuffer

getFamilyPosition

getQualifierByteBuffer

getQualifierPosition

getValueByteBuffer

getValuePosition

getTagsByteBuffer

getTagsPosition

toString

setSequenceId

setTimestamp

setTimestamp

heapSize

write

getSerializedSize

write

deepClone