| 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 |
GraphRowWriter
The operational, configuration and other state information required for write
operations on a single graph row.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<commonj.sdo.DataObject,RowWriter> |
WriterSupport.rowWriterMap |
| 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.
|
RowWriter |
DistributedWriter.createRowWriter(commonj.sdo.DataObject dataObject)
Creates and returns a new row writer associated with the given data object.
|
RowWriter |
DistributedGraphWriter.createRowWriter(commonj.sdo.DataObject dataObject)
Creates and returns a new row writer associated with the given data object.
|
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.
|
protected RowWriter |
WriterSupport.findContainerRowWriter(commonj.sdo.DataObject target)
Finds and return the row writer associated with the given target data
object
|
RowWriter |
DistributedWriter.findRowWriter(commonj.sdo.DataObject dataObject)
Returns the row writer associated with the given data object or null if no
row writer is associated.
|
RowWriter |
DistributedGraphWriter.findRowWriter(commonj.sdo.DataObject dataObject)
Returns the row writer associated with the given data object or null if no
row writer is associated.
|
protected RowWriter |
WriterSupport.getContainerRowWriter(commonj.sdo.DataObject target)
Finds and return the row writer associated with the container for the given
target data object
|
RowWriter |
GraphEdgeWriter.getRowWriter() |
RowWriter |
EdgeWriter.getRowWriter() |
RowWriter |
DistributedWriter.getRowWriter(commonj.sdo.DataObject dataObject)
Returns the row writer associated with the given data object
|
RowWriter |
DistributedGraphWriter.getRowWriter(commonj.sdo.DataObject dataObject)
Returns the row writer associated with the given data object
|
RowWriter |
TableWriter.getRowWriter(UUID uuid)
Returns the row writer context for the given UUID
|
RowWriter |
GraphTableWriter.getRowWriter(UUID uuid) |
| Modifier and Type | Method and Description |
|---|---|
List<RowWriter> |
TableWriter.getAllRowWriters()
Returns all row writer context values for this table context.
|
List<RowWriter> |
GraphTableWriter.getAllRowWriters() |
Map<commonj.sdo.DataObject,RowWriter> |
TableWriterCollector.getRowWriterMap() |
| Modifier and Type | Method and Description |
|---|---|
void |
TableWriter.addRowWriter(UUID uuid,
RowWriter rowContext)
Adds the given row writer context mapping it to the given UUID.
|
void |
GraphTableWriter.addRowWriter(UUID uuid,
RowWriter rowContext) |
| 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 |
Update.init(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Mutation.init(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter)
Performs any initialization for the specific mutation to be preformed.
|
void |
Delete.init(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Create.init(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter)
For create operation initializes the entity sequence and populates the
entity metadata
|
void |
Update.setup(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Mutation.setup(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter)
Performs any changes on managed properties such as concurrent or locking or
other, etc..
|
void |
Delete.setup(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Create.setup(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Update.validate(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Mutation.validate(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter)
Checks for a valid mutation such as no read-only properties being modified
and all mandatory properties being set, etc..
|
void |
Delete.validate(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
void |
Create.validate(commonj.sdo.DataGraph dataGraph,
org.plasma.sdo.PlasmaDataObject dataObject,
RowWriter rowWriter) |
Copyright © 2021. All Rights Reserved.