| Package | Description |
|---|---|
| org.cloudgraph.hbase.io |
Provides infrastructure for managing HBase read and write operations across
any number of HBase tables and/or rows.
|
| org.cloudgraph.hbase.mutation |
| Modifier and Type | Class and Description |
|---|---|
class |
GraphTableWriter
The operational, configuration and other state information required for write
operations on a single graph table.
|
| Modifier and Type | Method and Description |
|---|---|
TableWriter |
TableWriterCollector.getRootTableWriter() |
TableWriter |
DistributedWriter.getRootTableWriter()
Returns the table writer associated with the data graph root.
|
TableWriter |
DistributedGraphWriter.getRootTableWriter()
Returns the table writer associated with the data graph root.
|
TableWriter |
RowWriter.getTableWriter()
Returns the container for this writer.
|
TableWriter |
GraphRowWriter.getTableWriter() |
TableWriter |
GraphEdgeWriter.getTableWriter() |
TableWriter |
EdgeWriter.getTableWriter() |
TableWriter |
DistributedWriter.getTableWriter(String tableName)
Returns the table writer for the given configured table name.
|
TableWriter |
DistributedGraphWriter.getTableWriter(String tableName)
Returns the table writer for the given configured table name, or null of
not exists.
|
| Modifier and Type | Method and Description |
|---|---|
List<TableWriter> |
TableWriterCollector.getTableWriters() |
List<TableWriter> |
DistributedWriter.getTableWriters()
Returns all table writers for the this container
|
List<TableWriter> |
DistributedGraphWriter.getTableWriters()
Returns all table writers for the this container
|
| Modifier and Type | Method and Description |
|---|---|
protected RowWriter |
WriterSupport.addRowWriter(commonj.sdo.DataObject dataObject,
TableWriter tableWriter)
Creates adds and returns a new row writer for the given (row root) data
object.
|
void |
DistributedWriter.addTableWriter(TableWriter writer)
Adds the given table writer to the container
|
void |
DistributedGraphWriter.addTableWriter(TableWriter writer)
Adds the given table writer to the container
|
protected RowWriter |
WriterSupport.createRowWriter(TableWriter tableWriter,
commonj.sdo.DataObject target)
Creates and returns a new row writer for the given (row root) data object.
|
protected RowWriter |
WriterSupport.createRowWriter(TableWriter tableWriter,
commonj.sdo.DataObject dataObject,
byte[] rowKey)
Creates and returns a new row writer for the given (row root) data object.
|
List<commonj.sdo.Type> |
DistributedWriter.getTypes(TableWriter operation)
Returns a list of types associated with the given table operation.
|
List<commonj.sdo.Type> |
DistributedGraphWriter.getTypes(TableWriter operation)
Returns a list of types associated with the given table operation.
|
void |
DistributedWriter.setRootTableWriter(TableWriter writer)
Sets the table writer associated with the data graph root.
|
void |
DistributedGraphWriter.setRootTableWriter(TableWriter writer)
Sets the table writer associated with the data graph root.
|
| Constructor and Description |
|---|
GraphRowWriter(byte[] rowKey,
commonj.sdo.DataObject rootDataObject,
TableWriter tableWriter,
StoreMappingContext mappingContext) |
| Modifier and Type | Method and Description |
|---|---|
Map<TableWriter,Map<String,Mutations>> |
MutationCollector.collectChanges(commonj.sdo.DataGraph[] dataGraphs,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
GraphMutationCollector.collectChanges(commonj.sdo.DataGraph[] dataGraphs,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
MutationCollector.collectChanges(commonj.sdo.DataGraph dataGraph,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
GraphMutationCollector.collectChanges(commonj.sdo.DataGraph dataGraph,
Connection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
Update.collect(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
DistributedWriter graphWriter,
TableWriter tableWriter,
RowWriter rowWriter) |
void |
Mutation.collect(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
DistributedWriter graphWriter,
TableWriter context,
RowWriter rowContext)
Interprets mutations from the data given data object (entity) as registered
in the associated graph change summary, and collects these into a service
specific mutation, an HBase row mutation in this case.
|
void |
Delete.collect(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
DistributedWriter graphWriter,
TableWriter tableWriter,
RowWriter rowWriter) |
void |
Create.collect(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
DistributedWriter graphWriter,
TableWriter tableWriter,
RowWriter rowWriter)
Iterates over every property in the data object and pulls its value, as for
'create' operations, change summary does not register which properties are
changed, only that the object is created.
|
void |
GraphMutationWriter.writeChanges(TableWriter[] tableWriters,
Map<TableWriter,Map<String,Mutations>> mutations,
org.plasma.sdo.core.SnapshotMap snapshotMap,
String jobName) |
| Modifier and Type | Method and Description |
|---|---|
void |
GraphMutationWriter.writeChanges(TableWriter[] tableWriters,
Map<TableWriter,Map<String,Mutations>> mutations,
org.plasma.sdo.core.SnapshotMap snapshotMap,
String jobName) |
Copyright © 2021. All Rights Reserved.