org.cloudgraph.hbase.io

Interface TableWriter

All Superinterfaces:

TableOperation, TableState

All Known Implementing Classes:

GraphTableWriter

public interface TableWriter
extends TableOperation

Provides access to 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

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.
List<RowWriter>	getAllRowWriters() Returns all row writer context values for this table context.
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator()
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
boolean	hasConcurrentRows() Return whether any concurrent rows have been detected for the table writer.
void	setDistributedWriter(DistributedGraphWriter distributedGraphWriter) Deprecated.
void	setHasConcurrentRows(boolean value) Sets whether any concurrent rows have been detected for the table writer.

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

close, getDistributedOperation, getTable

Methods inherited from interface org.cloudgraph.state.TableState

getMappingContext, getTableConfig

Method Detail

getDistributedWriter

DistributedWriter getDistributedWriter()

getBufferedMutator

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

getQualifiedLogicalTableName

String getQualifiedLogicalTableName()

Returns the qualified logical table name associated with this reader.

Returns:

the qualified logical table name associated with this reader.

getQualifiedPhysicalTableName

String getQualifiedPhysicalTableName()

Returns the qualified physical table name associated with this reader.

Returns:

the qualified physical table name associated with this reader.

getQualifiedPhysicalTableNamespace

String getQualifiedPhysicalTableNamespace()

Returns the qualified physical table namespace associated with this reader.

Returns:

the qualified physical table namespace associated with this reader.

hasConcurrentRows

boolean hasConcurrentRows()

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

Returns:

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

setHasConcurrentRows

void setHasConcurrentRows(boolean value)

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

setDistributedWriter

@Deprecated
void setDistributedWriter(DistributedGraphWriter distributedGraphWriter)

Deprecated.

getRowWriter

RowWriter getRowWriter(UUID uuid)

Returns the row writer context for the given UUID

Parameters:

uuid - the UUID string

Returns:

the row writer context for the given UUID

addRowWriter

void addRowWriter(UUID uuid,
                  RowWriter rowContext)

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

Parameters:

uuid - the UUID

rowContext - the row writer context

getAllRowWriters

List<RowWriter> getAllRowWriters()

Returns all row writer context values for this table context.

Returns:

all row writer context values for this table context.