org.cloudgraph.hbase.io

Class GraphTableWriter

java.lang.Object

org.cloudgraph.state.GraphTable

org.cloudgraph.hbase.io.GraphTableWriter

All Implemented Interfaces:

TableOperation, TableWriter, TableState

public class GraphTableWriter
extends GraphTable
implements TableWriter

The operational, configuration and other state information required for write operations on a single graph table.

Acts as a container for one or more RowWriter elements and encapsulates the HBase client Put and Delete operations for use in write operations across one or more graph rows within a table.

Since:

0.5.1

Author:

Scott Cinnamond

See Also:

RowWriter

Field Summary

Fields

Modifier and Type	Field and Description
boolean	hasConcurentRows

Fields inherited from class org.cloudgraph.state.GraphTable

mappingContext, tableConfig

Constructor Summary

Constructors

Constructor and Description
GraphTableWriter(TableMapping table, DistributedGraphWriter distributedOperation, StoreMappingContext mappingContext)
GraphTableWriter(TableMapping table, StoreMappingContext mappingContext)

Method Summary

Modifier and Type	Method and Description
void	addRowWriter(UUID uuid, RowWriter rowContext) Adds the given row writer context mapping it to the given UUID.
void	close() Frees resources.
List<RowWriter>	getAllRowWriters() Returns all row writer context values for this table context.
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator()
DistributedGraphOperation	getDistributedOperation() Returns the distributed context associated with this table operation context.
DistributedWriter	getDistributedWriter()
String	getQualifiedLogicalTableName() Returns the qualified logical table name associated with this reader.
String	getQualifiedPhysicalTableName() Returns the qualified physical table name associated with this reader.
String	getQualifiedPhysicalTableNamespace() Returns the qualified physical table namespace associated with this reader.
RowWriter	getRowWriter(UUID uuid) Returns the row writer context for the given UUID
org.apache.hadoop.hbase.client.Table	getTable() Returns the HBase table pooled connection for this context.
boolean	hasConcurrentRows() Return whether any concurrent rows have been detected for the table writer.
void	setDistributedWriter(DistributedGraphWriter distributedGraphWriter)
void	setHasConcurrentRows(boolean value) Sets whether any concurrent rows have been detected for the table writer.

Methods inherited from class org.cloudgraph.state.GraphTable

getMappingContext, getTableConfig

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cloudgraph.state.TableState

getMappingContext, getTableConfig

Field Detail

hasConcurentRows

public boolean hasConcurentRows

Constructor Detail

GraphTableWriter

public GraphTableWriter(TableMapping table,
                        StoreMappingContext mappingContext)

GraphTableWriter

public GraphTableWriter(TableMapping table,
                        DistributedGraphWriter distributedOperation,
                        StoreMappingContext mappingContext)

Method Detail

getDistributedWriter

public DistributedWriter getDistributedWriter()

Specified by:

getDistributedWriter in interface TableWriter

setDistributedWriter

public void setDistributedWriter(DistributedGraphWriter distributedGraphWriter)

Specified by:

setDistributedWriter in interface TableWriter

getQualifiedLogicalTableName

public String getQualifiedLogicalTableName()

Returns the qualified logical table name associated with this reader.

Specified by:

getQualifiedLogicalTableName in interface TableWriter

Returns:

the qualified logical table name associated with this reader.

getQualifiedPhysicalTableName

public String getQualifiedPhysicalTableName()

Returns the qualified physical table name associated with this reader.

Specified by:

getQualifiedPhysicalTableName in interface TableWriter

Returns:

the qualified physical table name associated with this reader.

getQualifiedPhysicalTableNamespace

public String getQualifiedPhysicalTableNamespace()

Returns the qualified physical table namespace associated with this reader.

Specified by:

getQualifiedPhysicalTableNamespace in interface TableWriter

Returns:

the qualified physical table namespace associated with this reader.

getTable

public org.apache.hadoop.hbase.client.Table getTable()

Description copied from interface: TableOperation

Returns the HBase table pooled connection for this context.

Specified by:

getTable in interface TableOperation

Returns:

the HBase table pooled connection for this context.

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator()

Specified by:

getBufferedMutator in interface TableWriter

getRowWriter

public RowWriter getRowWriter(UUID uuid)

Description copied from interface: TableWriter

Returns the row writer context for the given UUID

Specified by:

getRowWriter in interface TableWriter

Parameters:

uuid - the UUID string

Returns:

the row writer context for the given UUID

addRowWriter

public void addRowWriter(UUID uuid,
                         RowWriter rowContext)

Description copied from interface: TableWriter

Adds the given row writer context mapping it to the given UUID.

Specified by:

addRowWriter in interface TableWriter

Parameters:

uuid - the UUID

rowContext - the row writer context

getAllRowWriters

public List<RowWriter> getAllRowWriters()

Description copied from interface: TableWriter

Returns all row writer context values for this table context.

Specified by:

getAllRowWriters in interface TableWriter

Returns:

all row writer context values for this table context.

getDistributedOperation

public DistributedGraphOperation getDistributedOperation()

Returns the distributed context associated with this table operation context.

Specified by:

getDistributedOperation in interface TableOperation

Returns:

the distributed context associated with this table operation context.

close

public void close()

Description copied from interface: TableOperation

Frees resources.

Specified by:

close in interface TableOperation

hasConcurrentRows

public boolean hasConcurrentRows()

Description copied from interface: TableWriter

Return whether any concurrent rows have been detected for the table writer. Optimization to enable bypassing of concurrent processing for an entire table.

Specified by:

hasConcurrentRows in interface TableWriter

Returns:

whether any concurrent rows have been detected for the table writer.

setHasConcurrentRows

public void setHasConcurrentRows(boolean value)

Description copied from interface: TableWriter

Sets whether any concurrent rows have been detected for the table writer. Optimization to enable bypassing of concurrent processing for an entire table.

Specified by:

setHasConcurrentRows in interface TableWriter