org.cloudgraph.hbase.mutation

Class GraphMutationCollector

java.lang.Object

org.cloudgraph.hbase.mutation.GraphMutationCollector

All Implemented Interfaces:

MutationCollector

Direct Known Subclasses:

GraphDispatcher

public class GraphMutationCollector
extends Object
implements MutationCollector

Traverses the change summary for one or more data graphs and collects changes in the form of HBase row mutations.

For each graph: - performs any change summary ordering - collects table writers based on graph metadata and configuration information - assembles table writers for the graph into a single graph writer composed of table writers, which are composed of row writers - passes each changed object (created, modified, deleted) along with the graph writer to logic within this class. - marshals out the state for each changed row after all changes complete in to the state column - for each row, detects if the root object is deleted, and then adds a toumbsone column

Since:

0.5.8

Author:

Scott Cinnamond

Field Summary

Fields

Modifier and Type	Field and Description
protected ServiceContext	context
protected Create	create
protected Delete	delete
protected org.plasma.sdo.core.SnapshotMap	snapshotMap
protected Update	update
protected String	username

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
Map<TableWriter,Map<String,Mutations>>	collectChanges(commonj.sdo.DataGraph[] dataGraphs, Connection connection)
Map<TableWriter,Map<String,Mutations>>	collectChanges(commonj.sdo.DataGraph dataGraph, Connection connection)
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 java.lang.Object

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

Field Detail

create

protected Create create

update

protected Update update

delete

protected Delete delete

snapshotMap

protected org.plasma.sdo.core.SnapshotMap snapshotMap

username

protected String username

context

protected ServiceContext context

Constructor Detail

GraphMutationCollector

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

Method Detail

close

public void close()

Specified by:

close in interface MutationCollector

collectChanges

public Map<TableWriter,Map<String,Mutations>> collectChanges(commonj.sdo.DataGraph dataGraph,
                                                             Connection connection)
                                                      throws IOException,
                                                             IllegalAccessException

Specified by:

collectChanges in interface MutationCollector

Throws:

IOException

IllegalAccessException

collectChanges

public Map<TableWriter,Map<String,Mutations>> collectChanges(commonj.sdo.DataGraph[] dataGraphs,
                                                             Connection connection)
                                                      throws IOException,
                                                             IllegalAccessException

Specified by:

collectChanges in interface MutationCollector

Throws:

IOException

IllegalAccessException

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)