org.cloudgraph.hbase.io

Class GraphRowReader

java.lang.Object

org.cloudgraph.state.GraphRow

org.cloudgraph.hbase.io.DefaultRowOperation

org.cloudgraph.hbase.io.GraphRowReader

All Implemented Interfaces:

RowOperation, RowReader, RowState

public class GraphRowReader
extends DefaultRowOperation
implements RowReader

The operational, configuration and other state information required for read operations on a single graph row.

Acts as a single component within a TableReader container and encapsulates the HBase client Get operation for use in read operations across multiple logical entities within a graph row.

Since:

0.5.1

Author:

Scott Cinnamond

See Also:

TableReader

Field Summary

Fields inherited from class org.cloudgraph.state.GraphRow

columnKeyFactory, graphConfig, ROOT_TYPE_DELIM, rootDataObject, rowKey, sequenceMapping

Constructor Summary

Constructors

Constructor and Description
GraphRowReader(byte[] rowKey, CellValues result, commonj.sdo.DataObject rootDataObject, TableReader tableReader, StoreMappingContext mappingContext)

Method Summary

Modifier and Type	Method and Description
void	clear() Frees resources associated with this reader.
org.plasma.sdo.PlasmaType	decodeType(byte[] bytes)
boolean	edgeExists(org.plasma.sdo.PlasmaType type, org.plasma.sdo.PlasmaProperty property, long sequence)
EdgeReader	getEdgeReader(org.plasma.sdo.PlasmaType type, org.plasma.sdo.PlasmaProperty property, long sequence)
StoreMappingContext	getMappingContext()
CellValues	getRow()
TableReader	getTableReader()

Methods inherited from class org.cloudgraph.state.GraphRow

addDataObject, addDataObject, contains, contains, contains, contains, getColumnKeyFactory, getDataGraph, getDataObject, getDataObject, getHashCode, getHashCode, getHashCode, getHashCode, getHashCode, getHashCode, getRootDataObject, getRootType, getRowKey, getSequenceMapping

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.cloudgraph.state.RowState

addDataObject, addDataObject, contains, contains, contains, contains, getColumnKeyFactory, getDataGraph, getDataObject, getDataObject, getRootDataObject, getRootType, getRowKey, getSequenceMapping

Constructor Detail

GraphRowReader

public GraphRowReader(byte[] rowKey,
                      CellValues result,
                      commonj.sdo.DataObject rootDataObject,
                      TableReader tableReader,
                      StoreMappingContext mappingContext)

Method Detail

getRow

public CellValues getRow()

Specified by:

getRow in interface RowReader

getTableReader

public TableReader getTableReader()

Specified by:

getTableReader in interface RowReader

getMappingContext

public StoreMappingContext getMappingContext()

Specified by:

getMappingContext in interface RowOperation

clear

public void clear()

Frees resources associated with this reader.

Specified by:

clear in interface RowReader

getEdgeReader

public EdgeReader getEdgeReader(org.plasma.sdo.PlasmaType type,
                                org.plasma.sdo.PlasmaProperty property,
                                long sequence)
                         throws IOException

Specified by:

getEdgeReader in interface RowReader

Throws:

IOException

edgeExists

public boolean edgeExists(org.plasma.sdo.PlasmaType type,
                          org.plasma.sdo.PlasmaProperty property,
                          long sequence)
                   throws IOException

Specified by:

edgeExists in interface RowReader

Throws:

IOException

decodeType

public org.plasma.sdo.PlasmaType decodeType(byte[] bytes)

Specified by:

decodeType in interface RowReader