org.cloudgraph.hbase.io

Class TableWriterCollector

java.lang.Object

org.cloudgraph.hbase.io.WriterSupport

org.cloudgraph.hbase.io.TableWriterCollector

public class TableWriterCollector
extends WriterSupport

Traverses the change summary of the given Data Graph collecting a list of TableWriter elements with nested RowWriter elements. Each RowWriter represents the root of a new or existing Data Graph within the HBase table associated with the parent TableWriter.

Graph nodes which are "unbound" (not assigned directly to a specific table) are assigned based on the first parent node within the graph. Other parent nodes (if exist) are ignored.

Since:

0.5.1

Author:

Scott Cinnamond

See Also:

StoreMapping, TableMapping, TableWriter, RowWriter, ChangeSummary

Field Summary

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

mappingContext, rowWriterMap

Constructor Summary

Constructors

Constructor and Description
TableWriterCollector(commonj.sdo.DataGraph dataGraph, org.plasma.sdo.PlasmaDataObject[] created, org.plasma.sdo.access.provider.common.ModifiedObjectCollector modified, org.plasma.sdo.access.provider.common.DeletedObjectCollector deleted, StoreMappingContext mappingContext)

Method Summary

Modifier and Type	Method and Description
TableWriter	getRootTableWriter()
Map<commonj.sdo.DataObject,RowWriter>	getRowWriterMap()
List<TableWriter>	getTableWriters()

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

addRowWriter, createRowWriter, createRowWriter, findContainerRowWriter, getContainerAncestry, getContainerRowWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

TableWriterCollector

public TableWriterCollector(commonj.sdo.DataGraph dataGraph,
                            org.plasma.sdo.PlasmaDataObject[] created,
                            org.plasma.sdo.access.provider.common.ModifiedObjectCollector modified,
                            org.plasma.sdo.access.provider.common.DeletedObjectCollector deleted,
                            StoreMappingContext mappingContext)
                     throws IOException

Throws:

IOException

Method Detail

getTableWriters

public List<TableWriter> getTableWriters()

getRootTableWriter

public TableWriter getRootTableWriter()

getRowWriterMap

public Map<commonj.sdo.DataObject,RowWriter> getRowWriterMap()