| 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.
|
| org.cloudgraph.hbase.results | |
| org.cloudgraph.hbase.service |
Contains HBase service provider implementation classes.
|
| Modifier and Type | Field and Description |
|---|---|
protected TableReader |
DefaultAssembler.rootTableReader |
| Modifier and Type | Method and Description |
|---|---|
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 |
DistributedAssembler.assembleExternalEdge(CellValues childValues,
EdgeReader edgeReader,
TableReader childTableReader,
org.plasma.sdo.PlasmaDataObject source,
long sourceSequence,
org.plasma.sdo.PlasmaProperty sourceProperty,
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 CellValues |
DefaultAssembler.fetchGraph(byte[] rowKey,
TableReader tableReader,
org.plasma.sdo.PlasmaType type)
Returns the selection graph as a single result.
|
protected org.plasma.sdo.PlasmaType |
DefaultAssembler.fetchRootType(TableReader childTableReader,
GraphColumnKeyFactory keyFactory,
org.plasma.sdo.PlasmaType subType,
CellValues childResult) |
protected UUID |
DefaultAssembler.fetchRootUUID(TableReader childTableReader,
GraphColumnKeyFactory keyFactory,
org.plasma.sdo.PlasmaType subType,
CellValues childResult) |
protected org.plasma.sdo.PlasmaType |
DefaultAssembler.findRootType(TableReader childTableReader,
GraphColumnKeyFactory keyFactory,
org.plasma.sdo.PlasmaType subType,
CellValues childResult) |
protected UUID |
DefaultAssembler.findRootUUID(TableReader childTableReader,
GraphColumnKeyFactory keyFactory,
org.plasma.sdo.PlasmaType subType,
CellValues childResult) |
| Constructor and Description |
|---|
DefaultAssembler(org.plasma.sdo.PlasmaType rootType,
org.plasma.query.collector.Selection selection,
TableReader rootTableReader,
Timestamp snapshotDate)
Constructor.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GraphTableReader
The operational, configuration and other state information required for read
operations on a single graph table.
|
| Modifier and Type | Method and Description |
|---|---|
TableReader |
DistributedReader.getRootTableReader()
Returns the table reader associated with the data graph root.
|
TableReader |
DistributedGraphReader.getRootTableReader()
Returns the table reader associated with the data graph root.
|
TableReader |
RowReader.getTableReader() |
TableReader |
GraphRowReader.getTableReader() |
TableReader |
GraphEdgeReader.getTableReader() |
TableReader |
EdgeReader.getTableReader() |
TableReader |
DistributedReader.getTableReader(QName qualifiedTypeName)
Returns the table reader for the given qualified type name.
|
TableReader |
DistributedGraphReader.getTableReader(QName qualifiedTypeName)
Returns the table reader for the given qualified type name, or null if not
exists.
|
TableReader |
DistributedReader.getTableReader(String tableName)
Returns the table reader for the given configured table name.
|
TableReader |
DistributedGraphReader.getTableReader(String tableName)
Returns the table reader for the given configured table name, or null of
not exists.
|
| Modifier and Type | Method and Description |
|---|---|
List<TableReader> |
DistributedReader.getTableReaders()
Returns all table readers for the this container
|
List<TableReader> |
DistributedGraphReader.getTableReaders()
Returns all table readers for the this container
|
| Modifier and Type | Method and Description |
|---|---|
void |
DistributedReader.addTableReader(TableReader reader)
Adds the given table reader to the container
|
void |
DistributedGraphReader.addTableReader(TableReader reader)
Adds the given table reader to the container
|
List<commonj.sdo.Type> |
DistributedReader.getTypes(TableReader operation)
Returns a list of types associated with the given table operation.
|
List<commonj.sdo.Type> |
DistributedGraphReader.getTypes(TableReader operation)
Returns a list of types associated with the given table reader.
|
void |
DistributedReader.setRootTableReader(TableReader reader)
Sets the table reader associated with the data graph root.
|
void |
DistributedGraphReader.setRootTableReader(TableReader reader)
Sets the table reader associated with the data graph root.
|
| Constructor and Description |
|---|
GraphRowReader(byte[] rowKey,
CellValues result,
commonj.sdo.DataObject rootDataObject,
TableReader tableReader,
StoreMappingContext mappingContext) |
| Modifier and Type | Field and Description |
|---|---|
protected TableReader |
DefaultResultsAssembler.rootTableReader |
| Constructor and Description |
|---|
DefaultResultsAssembler(Expr whereSyntaxTree,
Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
TableReader rootTableReader,
Integer startRange,
Integer endRange) |
ParallelSlidingResultsAssembler(Expr graphRecognizerRootExpr,
Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
TableReader rootTableReader,
GraphAssemblerFactory assemblerFactory,
Integer startRange,
Integer endRange,
ThreadPoolMappingProps poolProps) |
ResultsAggregator(org.plasma.query.collector.Selection selection,
Expr whereSyntaxTree,
ResultsComparator orderingComparator,
ResultsComparator groupingComparator,
Expr havingSyntaxTree,
TableReader rootTableReader,
HBaseGraphAssembler graphAssembler,
Integer startRange,
Integer endRange) |
SlidingResultsAssembler(Expr graphRecognizerRootExpr,
Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
TableReader rootTableReader,
HBaseGraphAssembler graphAssembler,
Integer startRange,
Integer endRange) |
StreamingResultsAssembler(Expr graphRecognizerRootExpr,
Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
TableReader rootTableReader,
HBaseGraphAssembler graphAssembler,
Integer startRange,
Integer endRange) |
| Modifier and Type | Method and Description |
|---|---|
protected ResultsAssembler |
GraphStreamQuery.createResultsAssembler(org.plasma.query.model.Query query,
org.plasma.query.collector.SelectionCollector selection,
Expr whereSyntaxTree,
ResultsComparator orderingComparator,
ResultsComparator groupingComparator,
Expr havingSyntaxTree,
TableReader rootTableReader,
GraphAssemblerFactory assemblerFactory) |
protected ResultsAssembler |
GraphQuery.createResultsAssembler(org.plasma.query.model.Query query,
org.plasma.query.collector.SelectionCollector selection,
Expr whereSyntaxTree,
ResultsComparator orderingComparator,
ResultsComparator groupingComparator,
Expr havingSyntaxTree,
TableReader rootTableReader,
GraphAssemblerFactory assemblerFactory) |
protected void |
GraphQuery.execute(CompleteRowKey rowKey,
TableReader rootTableReader,
org.apache.hadoop.hbase.filter.Filter columnFilter,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(FuzzyRowKey fuzzyScan,
TableReader rootTableReader,
org.apache.hadoop.hbase.filter.Filter columnFilter,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(org.apache.hadoop.hbase.client.Get get,
TableReader rootTableReader,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(List<CompleteRowKey> rowKeys,
TableReader rootTableReader,
org.apache.hadoop.hbase.filter.Filter columnFilter,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(List<org.apache.hadoop.hbase.client.Get> gets,
TableReader rootTableReader,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(PartialRowKey partialRowKey,
TableReader rootTableReader,
org.apache.hadoop.hbase.filter.Filter columnFilter,
ResultsAssembler collector) |
protected void |
GraphStreamQuery.execute(org.apache.hadoop.hbase.client.Scan scan,
TableReader rootTableReader,
ResultsAssembler collector) |
protected void |
GraphQuery.execute(org.apache.hadoop.hbase.client.Scan scan,
TableReader rootTableReader,
ResultsAssembler collector) |
Copyright © 2021. All Rights Reserved.