| 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 |
DistributedGraphWriter
Encapsulates one or more graph table writer components for federation across
multiple physical tables and/or physical table rows.
|
| Modifier and Type | Method and Description |
|---|---|
DistributedWriter |
TableWriter.getDistributedWriter() |
DistributedWriter |
GraphTableWriter.getDistributedWriter() |
| 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.
|
Copyright © 2021. All Rights Reserved.