| Package | Description |
|---|---|
| org.cloudgraph.hbase.graph |
Provides data graph assembly for both parallel/concurrent and serial/blocking contexts along with supporting infrastructure.
|
| org.cloudgraph.hbase.io |
Provides infrastructure for managing HBase read and write operations across
any number of HBase tables and/or rows.
|
| Modifier and Type | Method and Description |
|---|---|
RowReader |
Traversal.getRowReader() |
RowReader |
ReaderFrame.getRowReader() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ParallelGraphSliceAssembler.assemble(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader sourceCollection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
int level)
Creates a single task and begins the traversal from root in the current
thread.
|
protected void |
ParallelGraphAssembler.assemble(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader sourceCollection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
int level)
Creates a single task and begins the traversal from root in the current
thread.
|
protected void |
GraphSliceAssembler.assemble(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader sourceCollection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
int level) |
protected void |
GraphAssembler.assemble(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader sourceCollection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
int level) |
protected abstract void |
DistributedAssembler.assemble(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader collection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
int level)
Populates the given data object target, recursively fetching data for and
linking related data objects which make up the resulting directed graph.
|
protected void |
DefaultAssembler.assembleData(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
Set<commonj.sdo.Property> props,
RowReader rowReader) |
protected void |
DistributedAssembler.assembleEdge(long childSequence,
EdgeReader collection,
RowReader childRowReader,
org.plasma.sdo.PlasmaDataObject source,
long sourceSequence,
org.plasma.sdo.PlasmaProperty sourceProperty,
int level) |
protected void |
GraphAssembler.assembleEdges(org.plasma.sdo.PlasmaDataObject source,
long sourceSequence,
org.plasma.sdo.PlasmaProperty sourceProp,
EdgeReader collection,
RowReader rowReader,
TableReader childTableReader,
RowReader childRowReader,
int level) |
protected void |
GraphAssembler.assembleExternalEdges(org.plasma.sdo.PlasmaDataObject source,
long sourceSequence,
org.plasma.sdo.PlasmaProperty sourceProp,
EdgeReader collection,
RowReader rowReader,
TableReader childTableReader,
int level)
Assembles a given set of edges where the target is a different row, within
this table or another.
|
protected void |
DefaultAssembler.assembleUUID(org.plasma.sdo.PlasmaDataObject target,
long targetSequence,
EdgeReader edgeReader,
RowReader rowReader) |
protected org.plasma.sdo.PlasmaDataObject |
DefaultAssembler.createChild(long targetSequence,
EdgeOperation collection,
commonj.sdo.DataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
DataGraphMapping graphConfig) |
protected org.plasma.sdo.PlasmaType |
DefaultAssembler.fetchType(org.plasma.sdo.PlasmaType type,
long targetSequence,
EdgeReader edgeReader,
RowReader rowReader) |
protected UUID |
DefaultAssembler.fetchUUID(org.plasma.sdo.PlasmaType type,
long targetSequence,
EdgeReader edgeReader,
RowReader rowReader) |
protected byte[] |
DefaultAssembler.findMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
long sequence,
EntityMetaKey keyField,
TableMapping tableConfig,
RowReader rowReader) |
protected byte[] |
DefaultAssembler.findMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
org.plasma.sdo.PlasmaProperty property,
long sequence,
EntityMetaKey keyField,
TableMapping tableConfig,
RowReader rowReader) |
protected byte[] |
DefaultAssembler.getDataColumnValue(org.plasma.sdo.PlasmaDataObject target,
org.plasma.sdo.PlasmaProperty prop,
TableMapping tableConfig,
RowReader rowReader) |
protected byte[] |
DefaultAssembler.getDataColumnValue(org.plasma.sdo.PlasmaType type,
org.plasma.sdo.PlasmaProperty prop,
long typeSequenceNum,
TableMapping tableConfig,
RowReader rowReader)
Returns a value for the given property from the given row reader by
generating a column qualifier based on column key model configurations
settings, graph state information and other factors.
|
protected byte[] |
DefaultAssembler.getMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
EntityMetaKey keyField,
TableMapping tableConfig,
CellValues result,
RowReader rowReader) |
protected byte[] |
DefaultAssembler.getMetaDataColumnValue(org.plasma.sdo.PlasmaType type,
long sequence,
EntityMetaKey keyField,
TableMapping tableConfig,
RowReader rowReader) |
| Constructor and Description |
|---|
ReaderFrame(RowReader rowReader,
int level) |
Traversal(org.plasma.sdo.PlasmaDataObject subroot,
long subrootSequence,
EdgeReader collection,
org.plasma.sdo.PlasmaDataObject source,
org.plasma.sdo.PlasmaProperty sourceProperty,
RowReader rowReader,
boolean concurrent,
int level) |
| Modifier and Type | Class and Description |
|---|---|
class |
GraphRowReader
The operational, configuration and other state information required for read
operations on a single graph row.
|
| Modifier and Type | Method and Description |
|---|---|
RowReader |
TableReader.createRowReader(commonj.sdo.DataObject dataObject,
CellValues resultRow)
Creates and adds a row reader based on the given data object and result
row.
|
RowReader |
GraphTableReader.createRowReader(commonj.sdo.DataObject dataObject,
CellValues resultRow)
Creates and adds a row reader based on the given data object and result row
mapping it by UUID string and row key string.
|
RowReader |
GraphEdgeReader.getRowReader() |
RowReader |
EdgeReader.getRowReader() |
RowReader |
TableReader.getRowReader(byte[] rowKey)
Returns the row reader context for the given row key or null if null exists
|
RowReader |
GraphTableReader.getRowReader(byte[] rowKey)
Returns the row reader context for the given row key or null if null exists
|
RowReader |
TableReader.getRowReader(commonj.sdo.DataObject dataObject)
Returns the row reader context for the given data object or null if null
exists
|
RowReader |
GraphTableReader.getRowReader(commonj.sdo.DataObject dataObject)
Returns the row reader context for the given data object or null if null
exists
|
RowReader |
DistributedReader.getRowReader(commonj.sdo.DataObject dataObject)
Returns the row reader associated with the given data object
|
RowReader |
DistributedGraphReader.getRowReader(commonj.sdo.DataObject dataObject)
Returns the row reader associated with the given data object
|
RowReader |
TableReader.getRowReader(String rowKey)
Returns the row reader context for the given row key or null if null exists
|
RowReader |
GraphTableReader.getRowReader(String rowKey) |
RowReader |
TableReader.getRowReader(UUID uuid)
Returns the row reader context for the given UUID or null if null exists
|
RowReader |
GraphTableReader.getRowReader(UUID uuid)
Returns the row reader context for the given UUID
|
| Modifier and Type | Method and Description |
|---|---|
List<RowReader> |
TableReader.getAllRowReaders()
Returns all row reader context values for this table context.
|
List<RowReader> |
GraphTableReader.getAllRowReaders()
Returns all row reader context values for this table context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TableReader.addRowReader(String rowKey,
RowReader rowContext) |
void |
GraphTableReader.addRowReader(String rowKey,
RowReader rowReader) |
void |
TableReader.addRowReader(UUID uuid,
RowReader rowContext)
Adds the given row reader context mapping it to the given UUID.
|
void |
GraphTableReader.addRowReader(UUID uuid,
RowReader rowReader)
Adds the given row reader context mapping it to the given UUID
|
void |
DistributedReader.mapRowReader(byte[] rowKey,
RowReader rowReader) |
void |
DistributedGraphReader.mapRowReader(byte[] rowKey,
RowReader rowReader) |
void |
DistributedReader.mapRowReader(commonj.sdo.DataObject dataObject,
RowReader rowReader) |
void |
DistributedGraphReader.mapRowReader(commonj.sdo.DataObject dataObject,
RowReader rowReader) |
void |
DistributedReader.mapRowReader(long dataObjectSequence,
org.plasma.sdo.PlasmaType type,
RowReader rowReader) |
void |
DistributedGraphReader.mapRowReader(long dataObjectSequence,
org.plasma.sdo.PlasmaType type,
RowReader rowReader) |
Copyright © 2021. All Rights Reserved.