| 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.results | |
| org.cloudgraph.hbase.service |
Contains HBase service provider implementation classes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DistributedAssembler
Supports the assembly of a directed data graph which may span multiple HBase
tables and/or rows by maintaining a stack of row readers annotated with graph
"level" and other information.
|
class |
GraphAssembler
Constructs a data graph starting with a given root SDO type based on a map of
selected SDO properties, where properties are mapped by selected types
required in the result graph.
|
class |
GraphSliceAssembler
Assembles a data graph where one or more collections may be "sliced" based on
path predicates within the "selection graph".
|
class |
ParallelGraphAssembler
Constructs a data graph in parallel starting with a given root using the
given "selection graph", where processing proceeds as a breadth-first
traversal and tasks are dynamically added based on thread availability within
a shared thread pool.
|
class |
ParallelGraphSliceAssembler
Assembles a data graph in parallel where one or more collections may be
"sliced" based on path predicates within the "selection graph".
|
| Constructor and Description |
|---|
GraphAssemblerCallable(org.apache.hadoop.hbase.client.Result resultRow,
HBaseGraphAssembler graphAssembler) |
| Modifier and Type | Field and Description |
|---|---|
protected HBaseGraphAssembler |
StreamingResultsAssembler.graphAssembler |
protected HBaseGraphAssembler |
SlidingResultsAssembler.graphAssembler |
protected HBaseGraphAssembler |
ResultsAggregator.graphAssembler |
| Constructor and Description |
|---|
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 |
|---|---|
HBaseGraphAssembler |
GraphAssemblerFactory.createAssembler() |
Copyright © 2021. All Rights Reserved.