org.cloudgraph.hbase.graph

Class DefaultAssembler

java.lang.Object

org.cloudgraph.hbase.graph.DefaultAssembler

Direct Known Subclasses:

DistributedAssembler

public abstract class DefaultAssembler
extends Object

Supports both distributed and non-distributed graph assemblers by providing default functionality.

Since:

0.5.1

Author:

Scott Cinnamond

Field Summary

Fields

Modifier and Type	Field and Description
protected Charset	charset
protected DataGraphMapping	graph
protected Map<org.plasma.sdo.PlasmaType,GraphColumnKeyFactory>	keyFactories
protected org.plasma.sdo.PlasmaDataObject	root
protected TableReader	rootTableReader
protected org.plasma.sdo.PlasmaType	rootType
protected org.plasma.query.collector.Selection	selection
protected Timestamp	snapshotDate

Constructor Summary

Constructors

Constructor and Description
DefaultAssembler(org.plasma.sdo.PlasmaType rootType, org.plasma.query.collector.Selection selection, TableReader rootTableReader, Timestamp snapshotDate) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	assembleData(org.plasma.sdo.PlasmaDataObject target, long targetSequence, Set<commonj.sdo.Property> props, RowReader rowReader)
protected void	assembleUUID(org.plasma.sdo.PlasmaDataObject target, long targetSequence, EdgeReader edgeReader, RowReader rowReader)
protected org.plasma.sdo.PlasmaDataObject	createChild(long targetSequence, EdgeOperation collection, commonj.sdo.DataObject source, org.plasma.sdo.PlasmaProperty sourceProperty, RowReader rowReader, DataGraphMapping graphConfig)
protected org.plasma.sdo.PlasmaDataObject	createChild(org.plasma.sdo.PlasmaDataObject source, org.plasma.sdo.PlasmaProperty prop, UUID uuid, org.plasma.sdo.PlasmaType subType) Creates contained child data object with the same type as the given containment property or of a specific given sub-type as determined by querying the entity state.
protected org.plasma.sdo.PlasmaDataObject	createChild(UUID uuid, org.plasma.sdo.PlasmaType childType, long targetSequence, commonj.sdo.DataObject source, org.plasma.sdo.PlasmaProperty sourceProperty)
protected org.plasma.sdo.PlasmaDataObject	createRoot(GraphColumnKeyFactory keyFactory, CellValues resultRow)
protected CellValues	fetchGraph(byte[] rowKey, TableReader tableReader, org.plasma.sdo.PlasmaType type) Returns the selection graph as a single result.
protected org.plasma.sdo.PlasmaType	fetchRootType(TableReader childTableReader, GraphColumnKeyFactory keyFactory, org.plasma.sdo.PlasmaType subType, CellValues childResult)
protected UUID	fetchRootUUID(TableReader childTableReader, GraphColumnKeyFactory keyFactory, org.plasma.sdo.PlasmaType subType, CellValues childResult)
protected org.plasma.sdo.PlasmaType	fetchType(org.plasma.sdo.PlasmaType type, long targetSequence, EdgeReader edgeReader, RowReader rowReader)
protected UUID	fetchUUID(org.plasma.sdo.PlasmaType type, long targetSequence, EdgeReader edgeReader, RowReader rowReader)
protected byte[]	findMetaDataColumnValue(org.plasma.sdo.PlasmaType type, long sequence, EntityMetaKey keyField, TableMapping tableConfig, RowReader rowReader)
protected byte[]	findMetaDataColumnValue(org.plasma.sdo.PlasmaType type, org.plasma.sdo.PlasmaProperty property, long sequence, EntityMetaKey keyField, TableMapping tableConfig, RowReader rowReader)
protected org.plasma.sdo.PlasmaType	findRootType(TableReader childTableReader, GraphColumnKeyFactory keyFactory, org.plasma.sdo.PlasmaType subType, CellValues childResult)
protected UUID	findRootUUID(TableReader childTableReader, GraphColumnKeyFactory keyFactory, org.plasma.sdo.PlasmaType subType, CellValues childResult)
protected byte[]	getDataColumnValue(org.plasma.sdo.PlasmaDataObject target, org.plasma.sdo.PlasmaProperty prop, TableMapping tableConfig, RowReader rowReader)
protected byte[]	getDataColumnValue(org.plasma.sdo.PlasmaType type, org.plasma.sdo.PlasmaProperty prop, long typeSequenceNum, TableMapping tableConfig, RowReader rowReader) Returns a value for the given property from the given row reader by generating a column qualifier based on column key model configurations settings, graph state information and other factors.
org.plasma.sdo.PlasmaDataGraph	getDataGraph() Returns the assembled data graph.
protected GraphColumnKeyFactory	getKeyFactory(org.plasma.sdo.PlasmaType type)
protected byte[]	getMetaDataColumnValue(org.plasma.sdo.PlasmaType type, EntityMetaKey keyField, TableMapping tableConfig, CellValues result, RowReader rowReader)
protected byte[]	getMetaDataColumnValue(org.plasma.sdo.PlasmaType type, long sequence, EntityMetaKey keyField, TableMapping tableConfig, RowReader rowReader)
protected Set<commonj.sdo.Property>	getProperties(org.plasma.sdo.PlasmaDataObject target, org.plasma.sdo.PlasmaDataObject source, org.plasma.sdo.PlasmaProperty sourceProperty, int level)
protected Set<commonj.sdo.Property>	getProperties(org.plasma.sdo.PlasmaType type, org.plasma.sdo.PlasmaDataObject source, org.plasma.sdo.PlasmaProperty sourceProperty, int level)
protected void	link(org.plasma.sdo.PlasmaDataObject target, org.plasma.sdo.PlasmaDataObject source, commonj.sdo.Property sourceProperty) Associates the source data object with the target as a non-containment reference.

Methods inherited from class java.lang.Object

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

Field Detail

rootType

protected org.plasma.sdo.PlasmaType rootType

keyFactories

protected Map<org.plasma.sdo.PlasmaType,GraphColumnKeyFactory> keyFactories

root

protected org.plasma.sdo.PlasmaDataObject root

rootTableReader

protected TableReader rootTableReader

graph

protected DataGraphMapping graph

charset

protected Charset charset

selection

protected org.plasma.query.collector.Selection selection

snapshotDate

protected Timestamp snapshotDate

Constructor Detail

DefaultAssembler

public DefaultAssembler(org.plasma.sdo.PlasmaType rootType,
                        org.plasma.query.collector.Selection selection,
                        TableReader rootTableReader,
                        Timestamp snapshotDate)

Constructor.

Parameters:

rootType - the SDO root type for the result data graph

selection - the selection properties for the graph to assemble.

snapshotDate - the query snapshot date which is populated into every data object in the result data graph.

Method Detail

getDataGraph

public org.plasma.sdo.PlasmaDataGraph getDataGraph()

Returns the assembled data graph.

getKeyFactory

protected GraphColumnKeyFactory getKeyFactory(org.plasma.sdo.PlasmaType type)

createRoot

protected org.plasma.sdo.PlasmaDataObject createRoot(GraphColumnKeyFactory keyFactory,
                                                     CellValues resultRow)

createChild

protected org.plasma.sdo.PlasmaDataObject createChild(org.plasma.sdo.PlasmaDataObject source,
                                                      org.plasma.sdo.PlasmaProperty prop,
                                                      UUID uuid,
                                                      org.plasma.sdo.PlasmaType subType)
                                               throws IOException

Creates contained child data object with the same type as the given containment property or of a specific given sub-type as determined by querying the entity state.

Parameters:

source - the container data object

prop - the containment property

uuid - the uuid for the new child

subType - the specific (sub) type for the new child which may differ from the type for the containment property

Returns:

the new child data object

Throws:

IOException

createChild

protected org.plasma.sdo.PlasmaDataObject createChild(long targetSequence,
                                                      EdgeOperation collection,
                                                      commonj.sdo.DataObject source,
                                                      org.plasma.sdo.PlasmaProperty sourceProperty,
                                                      RowReader rowReader,
                                                      DataGraphMapping graphConfig)
                                               throws IOException

Throws:

IOException

createChild

protected org.plasma.sdo.PlasmaDataObject createChild(UUID uuid,
                                                      org.plasma.sdo.PlasmaType childType,
                                                      long targetSequence,
                                                      commonj.sdo.DataObject source,
                                                      org.plasma.sdo.PlasmaProperty sourceProperty)
                                               throws IOException

Throws:

IOException

assembleUUID

protected void assembleUUID(org.plasma.sdo.PlasmaDataObject target,
                            long targetSequence,
                            EdgeReader edgeReader,
                            RowReader rowReader)
                     throws IOException

Throws:

IOException

fetchUUID

protected UUID fetchUUID(org.plasma.sdo.PlasmaType type,
                         long targetSequence,
                         EdgeReader edgeReader,
                         RowReader rowReader)
                  throws IOException

Throws:

IOException

findRootUUID

protected UUID findRootUUID(TableReader childTableReader,
                            GraphColumnKeyFactory keyFactory,
                            org.plasma.sdo.PlasmaType subType,
                            CellValues childResult)

fetchRootUUID

protected UUID fetchRootUUID(TableReader childTableReader,
                             GraphColumnKeyFactory keyFactory,
                             org.plasma.sdo.PlasmaType subType,
                             CellValues childResult)

fetchRootType

protected org.plasma.sdo.PlasmaType fetchRootType(TableReader childTableReader,
                                                  GraphColumnKeyFactory keyFactory,
                                                  org.plasma.sdo.PlasmaType subType,
                                                  CellValues childResult)
                                           throws IOException

Throws:

IOException

findRootType

protected org.plasma.sdo.PlasmaType findRootType(TableReader childTableReader,
                                                 GraphColumnKeyFactory keyFactory,
                                                 org.plasma.sdo.PlasmaType subType,
                                                 CellValues childResult)
                                          throws IOException

Throws:

IOException

fetchType

protected org.plasma.sdo.PlasmaType fetchType(org.plasma.sdo.PlasmaType type,
                                              long targetSequence,
                                              EdgeReader edgeReader,
                                              RowReader rowReader)
                                       throws IOException

Throws:

IOException

assembleData

protected void assembleData(org.plasma.sdo.PlasmaDataObject target,
                            long targetSequence,
                            Set<commonj.sdo.Property> props,
                            RowReader rowReader)
                     throws IOException

Throws:

IOException

getMetaDataColumnValue

protected byte[] getMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
                                        long sequence,
                                        EntityMetaKey keyField,
                                        TableMapping tableConfig,
                                        RowReader rowReader)
                                 throws IOException

Throws:

IOException

getMetaDataColumnValue

protected byte[] getMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
                                        EntityMetaKey keyField,
                                        TableMapping tableConfig,
                                        CellValues result,
                                        RowReader rowReader)
                                 throws IOException

Throws:

IOException

findMetaDataColumnValue

protected byte[] findMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
                                         org.plasma.sdo.PlasmaProperty property,
                                         long sequence,
                                         EntityMetaKey keyField,
                                         TableMapping tableConfig,
                                         RowReader rowReader)
                                  throws IOException

Throws:

IOException

findMetaDataColumnValue

protected byte[] findMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
                                         long sequence,
                                         EntityMetaKey keyField,
                                         TableMapping tableConfig,
                                         RowReader rowReader)
                                  throws IOException

Throws:

IOException

getDataColumnValue

protected byte[] getDataColumnValue(org.plasma.sdo.PlasmaType type,
                                    org.plasma.sdo.PlasmaProperty prop,
                                    long typeSequenceNum,
                                    TableMapping tableConfig,
                                    RowReader rowReader)
                             throws IOException

Returns a value for the given property from the given row reader by generating a column qualifier based on column key model configurations settings, graph state information and other factors. Returns null if the qualifier does not exist.

Parameters:

target - the data object

prop - the property

typeSequenceNum - the graph row specific sequence number for the given type for a data object

tableConfig - the table configuration

rowReader - the row reader

Returns:

a value for the given property from the given row reader by generating a column qualifier based on column key model configurations settings, graph state information and other factors.

Throws:

IOException - if a remote or network exception occurs.

getDataColumnValue

protected byte[] getDataColumnValue(org.plasma.sdo.PlasmaDataObject target,
                                    org.plasma.sdo.PlasmaProperty prop,
                                    TableMapping tableConfig,
                                    RowReader rowReader)
                             throws IOException

Throws:

IOException

getProperties

protected Set<commonj.sdo.Property> getProperties(org.plasma.sdo.PlasmaDataObject target,
                                                  org.plasma.sdo.PlasmaDataObject source,
                                                  org.plasma.sdo.PlasmaProperty sourceProperty,
                                                  int level)

getProperties

protected Set<commonj.sdo.Property> getProperties(org.plasma.sdo.PlasmaType type,
                                                  org.plasma.sdo.PlasmaDataObject source,
                                                  org.plasma.sdo.PlasmaProperty sourceProperty,
                                                  int level)

link

protected void link(org.plasma.sdo.PlasmaDataObject target,
                    org.plasma.sdo.PlasmaDataObject source,
                    commonj.sdo.Property sourceProperty)

Associates the source data object with the target as a non-containment reference.

Parameters:

target - the data object target

source - the data object source

sourceProperty - the reference property

Throws:

IllegalStateException - if the target data object does not have a container

fetchGraph

protected CellValues fetchGraph(byte[] rowKey,
                                TableReader tableReader,
                                org.plasma.sdo.PlasmaType type)
                         throws IOException

Returns the selection graph as a single result.

Parameters:

rowKey - the row key

tableReader - the table reader

dataObject - the

Returns:

the selection graph as a single result.

Throws:

IOException - if a remote or network exception occurs.

See Also:

GraphFetchColumnFilterAssembler