org.cloudgraph.hbase.io

Interface EdgeWriter

All Superinterfaces:

EdgeOperation

All Known Implementing Classes:

GraphEdgeWriter

public interface EdgeWriter
extends EdgeOperation

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 interface org.cloudgraph.hbase.io.EdgeOperation

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

Method Detail

getRowWriter

RowWriter getRowWriter()

getTableWriter

TableWriter getTableWriter()

replace

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

Throws:

IOException

remove

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

Throws:

IOException

add

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

Throws:

IOException

addAll

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

Throws:

IOException

merge

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

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.

Parameters:

oldValueList -

currentEdges -

Throws:

IOException

write

void write()
    throws IOException

Throws:

IOException

delete

void delete()
     throws IOException

Throws:

IOException