org.cloudgraph.hbase.mutation

Class Delete

java.lang.Object

org.cloudgraph.hbase.mutation.Delete

All Implemented Interfaces:

Mutation

public class Delete
extends Object
implements Mutation

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	collect(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, DistributedWriter graphWriter, TableWriter tableWriter, RowWriter rowWriter) Interprets mutations from the data given data object (entity) as registered in the associated graph change summary, and collects these into a service specific mutation, an HBase row mutation in this case.
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)
void	init(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, RowWriter rowWriter) Performs any initialization for the specific mutation to be preformed.
void	setup(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, RowWriter rowWriter) Performs any changes on managed properties such as concurrent or locking or other, etc..
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)
void	validate(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, RowWriter rowWriter) Checks for a valid mutation such as no read-only properties being modified and all mandatory properties being set, etc..
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

snapshotMap

protected org.plasma.sdo.core.SnapshotMap snapshotMap

username

protected String username

context

protected ServiceContext context

Constructor Detail

Delete

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

Method Detail

init

public void init(commonj.sdo.DataGraph dataGraph,
                 org.plasma.sdo.PlasmaDataObject dataObject,
                 RowWriter rowWriter)
          throws IllegalAccessException,
                 IOException

Description copied from interface: Mutation

Performs any initialization for the specific mutation to be preformed.

Specified by:

init in interface Mutation

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

IOException

validate

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

Description copied from interface: Mutation

Checks for a valid mutation such as no read-only properties being modified and all mandatory properties being set, etc..

Specified by:

validate in interface Mutation

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

setup

public void setup(commonj.sdo.DataGraph dataGraph,
                  org.plasma.sdo.PlasmaDataObject dataObject,
                  RowWriter rowWriter)
           throws IllegalAccessException,
                  IOException

Description copied from interface: Mutation

Performs any changes on managed properties such as concurrent or locking or other, etc..

Specified by:

setup in interface Mutation

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

IOException

collect

public void collect(commonj.sdo.DataGraph dataGraph,
                    org.plasma.sdo.PlasmaDataObject dataObject,
                    DistributedWriter graphWriter,
                    TableWriter tableWriter,
                    RowWriter rowWriter)
             throws IOException,
                    IllegalAccessException

Description copied from interface: Mutation

Interprets mutations from the data given data object (entity) as registered in the associated graph change summary, and collects these into a service specific mutation, an HBase row mutation in this case.

Specified by:

collect in interface Mutation

Parameters:

dataGraph - the data graph

dataObject - the data object

graphWriter - the graph writer

tableWriter - the table writer

rowWriter - the row writer

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)