org.cloudgraph.hbase.service

Class GraphDispatcher

java.lang.Object

org.cloudgraph.hbase.mutation.GraphMutationCollector

org.cloudgraph.hbase.service.GraphDispatcher

All Implemented Interfaces:

MutationCollector, org.plasma.sdo.access.DataGraphDispatcher

public class GraphDispatcher
extends GraphMutationCollector
implements org.plasma.sdo.access.DataGraphDispatcher

Propagates changes to a data graph including any number of creates (inserts), modifications (updates) and deletes across one or more HBase table rows.

For new (created) data graphs, a row key {org.cloudgraph.hbase.key.HBaseRowKeyFactory factory} is used to create a new composite HBase row key. The row key generation is driven by a configured CloudGraph row key model for a specific HTable configuration. A minimal set of state information is persisted with each new data graph.

For data graphs with any other combination of changes, e.g. data object modifications, deletes, etc... an existing HBase row key is fetched using an HBase Get operation.

Since:

0.5

Author:

Scott Cinnamond

See Also:

DistributedWriter, GraphRowKeyFactory, GraphColumnKeyFactory, SequenceGenerator

Field Summary

Fields

Modifier and Type	Field and Description
protected ServiceContext	context
protected org.plasma.sdo.core.SnapshotMap	snapshotMap
protected String	username

Fields inherited from class org.cloudgraph.hbase.mutation.GraphMutationCollector

create, delete, update

Constructor Summary

Constructors

Constructor and Description
GraphDispatcher(ServiceContext context, org.plasma.sdo.core.SnapshotMap snapshotMap, String username)

Method Summary

Modifier and Type	Method and Description
void	close()
org.plasma.sdo.core.SnapshotMap	commit(commonj.sdo.DataGraph dataGraph) Propagates changes to the given data graph including any number of creates (inserts), modifications (updates) and deletes to a single or multiple HBase tables and table rows.
org.plasma.sdo.core.SnapshotMap	commit(commonj.sdo.DataGraph[] dataGraphs) Propagates changes to the given array of data graphs including any number of creates (inserts), modifications (updates) and deletes to a single or multiple HBase tables and table rows.
protected List<org.plasma.sdo.PlasmaEdge>	findOwnedEdges(org.plasma.sdo.PlasmaNode dataNode, commonj.sdo.Property property, List<org.plasma.sdo.PlasmaEdge> edges, DistributedWriter graphWriter, RowWriter rowWriter) Deprecated.
protected HashMap<String,commonj.sdo.DataObject>	getOldEdgeMap(Object oldValue, commonj.sdo.Property property)
protected void	setupOptimistic(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, org.plasma.sdo.PlasmaType type, long sequence, RowWriter rowWriter)
protected void	setupOrigination(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, org.plasma.sdo.PlasmaType type, long sequence, RowWriter rowWriter)
protected String	toString(Map<String,commonj.sdo.DataObject> map)
protected void	validateModifications(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, RowWriter rowWriter)

Methods inherited from class org.cloudgraph.hbase.mutation.GraphMutationCollector

collectChanges, collectChanges

Methods inherited from class java.lang.Object

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

Field Detail

snapshotMap

protected org.plasma.sdo.core.SnapshotMap snapshotMap

username

protected String username

context

protected ServiceContext context

Constructor Detail

GraphDispatcher

public GraphDispatcher(ServiceContext context,
                       org.plasma.sdo.core.SnapshotMap snapshotMap,
                       String username)

Method Detail

close

public void close()

Specified by:

close in interface MutationCollector

Specified by:

close in interface org.plasma.sdo.access.DataGraphDispatcher

Overrides:

close in class GraphMutationCollector

commit

public org.plasma.sdo.core.SnapshotMap commit(commonj.sdo.DataGraph dataGraph)

Propagates changes to the given data graph including any number of creates (inserts), modifications (updates) and deletes to a single or multiple HBase tables and table rows.

Specified by:

commit in interface org.plasma.sdo.access.DataGraphDispatcher

Returns:

a map of internally managed concurrency property values and data store generated keys.

Throws:

DuplicateRowException - if for a new data graph, the generated row key already exists in the HBase table configured .

commit

public org.plasma.sdo.core.SnapshotMap commit(commonj.sdo.DataGraph[] dataGraphs)

Propagates changes to the given array of data graphs including any number of creates (inserts), modifications (updates) and deletes to a single or multiple HBase tables and table rows. The given graphs may be heterogeneous, with different root data objects any 'shape' or depth.

Specified by:

commit in interface org.plasma.sdo.access.DataGraphDispatcher

Returns:

a map of internally managed concurrency property values and data store generated keys.

Throws:

DuplicateRowException - if for a new data graph, the generated row key already exists in the HBase table configured .

getOldEdgeMap

protected HashMap<String,commonj.sdo.DataObject> getOldEdgeMap(Object oldValue,
                                                               commonj.sdo.Property property)

findOwnedEdges

@Deprecated
protected List<org.plasma.sdo.PlasmaEdge> findOwnedEdges(org.plasma.sdo.PlasmaNode dataNode,
                                                                      commonj.sdo.Property property,
                                                                      List<org.plasma.sdo.PlasmaEdge> edges,
                                                                      DistributedWriter graphWriter,
                                                                      RowWriter rowWriter)
                                                               throws IOException

Deprecated.

Screens out edges that are not owned by the given data node, but still may be present.

Throws:

IOException

setupOptimistic

protected void setupOptimistic(commonj.sdo.DataGraph dataGraph,
                               org.plasma.sdo.PlasmaDataObject dataObject,
                               org.plasma.sdo.PlasmaType type,
                               long sequence,
                               RowWriter rowWriter)
                        throws IOException

Throws:

IOException

setupOrigination

protected void setupOrigination(commonj.sdo.DataGraph dataGraph,
                                org.plasma.sdo.PlasmaDataObject dataObject,
                                org.plasma.sdo.PlasmaType type,
                                long sequence,
                                RowWriter rowWriter)
                         throws IOException

Throws:

IOException

validateModifications

protected void validateModifications(commonj.sdo.DataGraph dataGraph,
                                     org.plasma.sdo.PlasmaDataObject dataObject,
                                     RowWriter rowWriter)
                              throws IllegalAccessException

Throws:

IllegalAccessException

toString

protected String toString(Map<String,commonj.sdo.DataObject> map)