org.cloudgraph.hbase.io

Class GraphEdgeWriter

java.lang.Object

org.cloudgraph.hbase.io.DefaultEdgeOperation

org.cloudgraph.hbase.io.GraphEdgeWriter

All Implemented Interfaces:

EdgeOperation, EdgeWriter

public class GraphEdgeWriter
extends DefaultEdgeOperation
implements EdgeWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.cloudgraph.hbase.io.DefaultEdgeOperation

DefaultEdgeOperation.KeyBytes

Field Summary

Fields inherited from class org.cloudgraph.hbase.io.DefaultEdgeOperation

baseTypeQual, charset, collectionBaseType, collectionDefaultSubType, collectionPath, columnKeyFeildDelim, columnKeyFeildDelimRegexp, countQual, countQualStr, family, graphConfig, keysQual, keysQualStr, pathQual, pathQualStr, rowKeys, rowOperation, sequences, sequencesQual, sequencesQualStr, sourceProp, sourceType, subTypeQual, tableConfig, TYPE_DELIM, TYPE_DELIM_REGEXP, typeQualStr

Method Summary

Modifier and Type	Method and Description
void	add(org.plasma.sdo.PlasmaDataObject newValue)
void	addAll(org.plasma.sdo.PlasmaNode dataNode, List<org.plasma.sdo.PlasmaEdge> edges)
void	delete()
RowWriter	getRowWriter()
TableWriter	getTableWriter()
void	merge(org.plasma.sdo.PlasmaNode dataNode, HashSet<org.plasma.sdo.PlasmaDataObject> oldValues, List<org.plasma.sdo.PlasmaEdge> currentEdges) Determines which object the user intentionally removed and/or added based on the change summary of the client graph.
void	remove(org.plasma.sdo.PlasmaDataObject oldValue)
void	replace(org.plasma.sdo.PlasmaDataObject oldValue, org.plasma.sdo.PlasmaDataObject newValue)
void	write()

Methods inherited from class org.cloudgraph.hbase.io.DefaultEdgeOperation

decodeCollectionBaseType, decodeDefaultSubType, decodeRowKeys, decodeSequences, decodeType, encodeCollectionBaseType, encodeDefaultSubType, encodeRowKeys, encodeSequences, encodeType, fetchValue, fetchValue, fetchValue, findValue, findValue, findValue, getBaseType, getCount, getPath, getRowKeys, getSequences, getSourceProp, getSubType, getTable, getTargetType, hasSequence, isExternal, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cloudgraph.hbase.io.EdgeOperation

getBaseType, getCount, getPath, getRowKeys, getSequences, getSubType, getTable, hasSequence, isExternal

Method Detail

getRowWriter

public RowWriter getRowWriter()

Specified by:

getRowWriter in interface EdgeWriter

getTableWriter

public TableWriter getTableWriter()

Specified by:

getTableWriter in interface EdgeWriter

replace

public void replace(org.plasma.sdo.PlasmaDataObject oldValue,
                    org.plasma.sdo.PlasmaDataObject newValue)
             throws IOException

Specified by:

replace in interface EdgeWriter

Throws:

IOException

remove

public void remove(org.plasma.sdo.PlasmaDataObject oldValue)
            throws IOException

Specified by:

remove in interface EdgeWriter

Throws:

IOException

add

public void add(org.plasma.sdo.PlasmaDataObject newValue)
         throws IOException

Specified by:

add in interface EdgeWriter

Throws:

IOException

addAll

public void addAll(org.plasma.sdo.PlasmaNode dataNode,
                   List<org.plasma.sdo.PlasmaEdge> edges)
            throws IOException

Specified by:

addAll in interface EdgeWriter

Throws:

IOException

merge

public void merge(org.plasma.sdo.PlasmaNode dataNode,
                  HashSet<org.plasma.sdo.PlasmaDataObject> oldValues,
                  List<org.plasma.sdo.PlasmaEdge> currentEdges)
           throws IOException

Description copied from interface: EdgeWriter

Determines which object the user intentionally removed and/or added based on the change summary of the client graph. Then removes and/or adds to the existing collection, just what the user has indicated.

Note: the client edge collection can be the results from a slice query where not all the collection results are returned. We don't want to remove what we DON'T find in the commit graph in this case.

Specified by:

merge in interface EdgeWriter

Throws:

IOException

write

public void write()
           throws IOException

Specified by:

write in interface EdgeWriter

Throws:

IOException

delete

public void delete()
            throws IOException

Specified by:

delete in interface EdgeWriter

Throws:

IOException