org.cloudgraph.hbase.mutation

Interface Mutation

All Known Implementing Classes:

Create, Delete, Update

public interface Mutation

Represents a mutation for a single entity within a graph.

Author:

Scott Cinnamond

Method Summary

Modifier and Type	Method and Description
void	collect(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject dataObject, DistributedWriter graphWriter, TableWriter context, RowWriter rowContext) 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.
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..
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..

Method Detail

init

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

Performs any initialization for the specific mutation to be preformed.

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

IOException

validate

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

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

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

setup

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

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

Parameters:

dataGraph - the data graph

dataObject - the data object

rowWriter - the row writer

Throws:

IllegalAccessException

IOException

collect

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

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.

Parameters:

dataGraph - the data graph

dataObject - the data object

graphWriter - the graph writer

context - the table writer

rowContext - the row writer

Throws:

IOException

IllegalAccessException