org.cloudgraph.hbase.io

Interface DistributedWriter

All Superinterfaces:

DistributedGraphOperation

All Known Implementing Classes:

DistributedGraphWriter

public interface DistributedWriter
extends DistributedGraphOperation

Encapsulates one or more graph table writer components for federation across multiple physical tables and/or physical table rows.

Acts as a container for one or more TableWriter elements encapsulating a set of component table write operations for federation across multiple tables, or a single table in the most simple (degenerate) case.

Since:

0.5.1

Author:

Scott Cinnamond

See Also:

GraphTableWriter, GraphTable

Method Summary

Modifier and Type	Method and Description
void	addTableWriter(TableWriter writer) Adds the given table writer to the container
RowWriter	createRowWriter(commonj.sdo.DataObject dataObject) Creates and returns a new row writer associated with the given data object.
RowWriter	findRowWriter(commonj.sdo.DataObject dataObject) Returns the row writer associated with the given data object or null if no row writer is associated.
TableWriter	getRootTableWriter() Returns the table writer associated with the data graph root.
RowWriter	getRowWriter(commonj.sdo.DataObject dataObject) Returns the row writer associated with the given data object
TableWriter	getTableWriter(String tableName) Returns the table writer for the given configured table name.
int	getTableWriterCount() Returns the count of table writers for this container.
List<TableWriter>	getTableWriters() Returns all table writers for the this container
List<commonj.sdo.Type>	getTypes(TableWriter operation) Returns a list of types associated with the given table operation.
void	setRootTableWriter(TableWriter writer) Sets the table writer associated with the data graph root.

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

close, getConnection, getMappingContext, hasSingleRootType

Method Detail

getTableWriter

TableWriter getTableWriter(String tableName)

Returns the table writer for the given configured table name.

Parameters:

tableName - the name of the configured table.

Returns:

the table writer for the given configured table name.

addTableWriter

void addTableWriter(TableWriter writer)

Adds the given table writer to the container

Parameters:

writer - the table writer.

getTableWriterCount

int getTableWriterCount()

Returns the count of table writers for this container.

Returns:

the count of table writers for this container

getTableWriters

List<TableWriter> getTableWriters()

Returns all table writers for the this container

Returns:

all table writers for the this container

getRootTableWriter

TableWriter getRootTableWriter()

Returns the table writer associated with the data graph root.

Returns:

the table writer associated with the data graph root.

setRootTableWriter

void setRootTableWriter(TableWriter writer)

Sets the table writer associated with the data graph root.

Parameters:

writer - the table writer

findRowWriter

RowWriter findRowWriter(commonj.sdo.DataObject dataObject)

Returns the row writer associated with the given data object or null if no row writer is associated.

Parameters:

dataObject - the data object

Returns:

the row writer associated with the given data object or null if no row writer is associated.

getRowWriter

RowWriter getRowWriter(commonj.sdo.DataObject dataObject)

Returns the row writer associated with the given data object

Parameters:

dataObject - the data object

Returns:

the row writer associated with the given data object

Throws:

IllegalArgumentException - if the given data object is not associated with any row writer.

createRowWriter

RowWriter createRowWriter(commonj.sdo.DataObject dataObject)
                   throws IOException

Creates and returns a new row writer associated with the given data object.

Parameters:

dataObject - the data object

Returns:

a new row writer associated with the given data object.

Throws:

IllegalArgumentException - if the given data object is already associated with a row writer.

IOException

getTypes

List<commonj.sdo.Type> getTypes(TableWriter operation)

Returns a list of types associated with the given table operation.

Parameters:

reader - the table operation

Returns:

a list of types associated with the given table operation.