org.cloudgraph.hbase.io

Class WriterSupport

java.lang.Object

org.cloudgraph.hbase.io.WriterSupport

Direct Known Subclasses:

DistributedGraphWriter, TableWriterCollector

public abstract class WriterSupport
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected StoreMappingContext	mappingContext
protected Map<commonj.sdo.DataObject,RowWriter>	rowWriterMap

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WriterSupport(StoreMappingContext mappingContext)

Method Summary

Modifier and Type	Method and Description
protected RowWriter	addRowWriter(commonj.sdo.DataObject dataObject, TableWriter tableWriter) Creates adds and returns a new row writer for the given (row root) data object.
protected RowWriter	createRowWriter(TableWriter tableWriter, commonj.sdo.DataObject target) Creates and returns a new row writer for the given (row root) data object.
protected RowWriter	createRowWriter(TableWriter tableWriter, commonj.sdo.DataObject dataObject, byte[] rowKey) Creates and returns a new row writer for the given (row root) data object.
protected RowWriter	findContainerRowWriter(commonj.sdo.DataObject target) Finds and return the row writer associated with the given target data object
protected List<commonj.sdo.DataObject>	getContainerAncestry(commonj.sdo.DataObject target) Traverses the container links for the given data object returning the ancestry as an ordered list.
protected RowWriter	getContainerRowWriter(commonj.sdo.DataObject target) Finds and return the row writer associated with the container for the given target data object

Methods inherited from class java.lang.Object

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

Field Detail

rowWriterMap

protected Map<commonj.sdo.DataObject,RowWriter> rowWriterMap

mappingContext

protected StoreMappingContext mappingContext

Constructor Detail

WriterSupport

protected WriterSupport(StoreMappingContext mappingContext)

Method Detail

getContainerRowWriter

protected RowWriter getContainerRowWriter(commonj.sdo.DataObject target)

Finds and return the row writer associated with the container for the given target data object

Parameters:

target - the target data object

Returns:

the row writer associated with the container for the given target data object

Throws:

OperationException - if no row writer found

findContainerRowWriter

protected RowWriter findContainerRowWriter(commonj.sdo.DataObject target)

Finds and return the row writer associated with the given target data object

Parameters:

target - the target data object

Returns:

the row writer associated with the given target data object, or null if no writer found

getContainerAncestry

protected List<commonj.sdo.DataObject> getContainerAncestry(commonj.sdo.DataObject target)

Traverses the container links for the given data object returning the ancestry as an ordered list.

Parameters:

target -

Returns:

createRowWriter

protected RowWriter createRowWriter(TableWriter tableWriter,
                                    commonj.sdo.DataObject target)
                             throws IOException

Creates and returns a new row writer for the given (row root) data object. If an existing row key is set into the instance property collection for the (row root) data object, the existing row key is used, otherwise a row key is generated. For objects flagged as deleted in the SDO change summary, re-generating a row key may not be possible, as for deleted operations SDO requires the removal of all properties (other than read-only) for all deleted data objects. If such removed properties are required for a row key, this makes re-generation for the row key impossible, and the key generator will throw an error.

Parameters:

tableWriter - the table writer

target - the target (row root) data object

Returns:

the new row writer

Throws:

IOException

createRowWriter

protected RowWriter createRowWriter(TableWriter tableWriter,
                                    commonj.sdo.DataObject dataObject,
                                    byte[] rowKey)
                             throws IOException

Creates and returns a new row writer for the given (row root) data object.

Parameters:

tableWriter - the table context

dataObject - the (row root) data object

rowKey - the existing row key

Returns:

the new row writer

Throws:

IOException

addRowWriter

protected RowWriter addRowWriter(commonj.sdo.DataObject dataObject,
                                 TableWriter tableWriter)
                          throws IOException

Creates adds and returns a new row writer for the given (row root) data object. If an existing row key is set into the instance property collection for the (row root) data object, the existing row key is used, otherwise a row key is generated. For objects flagged as deleted in the SDO change summary, re-generating a row key may not be possible, as for deleted operations SDO requires the removal of all properties (other than read-only) for all deleted data objects. If such removed properties are required for a row key, this makes re-generation for the row key impossible, and the key generator will throw an error.

Parameters:

dataObject - the target (row root) data object

tableWriter - the table context

Returns:

the new row writer

Throws:

IOException