org.cloudgraph.hbase.mutation

Interface MutationCollector

All Known Implementing Classes:

GraphDispatcher, GraphMutationCollector

public interface 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

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)

Method Detail

collectChanges

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

Throws:

IOException

IllegalAccessException

collectChanges

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

Throws:

IOException

IllegalAccessException

close

void close()