| Package | Description |
|---|---|
| org.cloudgraph.hbase.results | |
| org.cloudgraph.hbase.service |
Contains HBase service provider implementation classes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultResultsAssembler
Default functionality for various results assemblers.
|
class |
ParallelSlidingResultsAssembler
Parallel results assembler which collects callable tasks then, lazily invokes
the resulting
futures before returning
results, the graphs being assembled by individual
GraphAssemblerCallable instances rather than by reusing the same
assembler. |
class |
ResultsAggregator
Assembler which executes aggregate functions, grouping and having clause
syntax tree evaluation.
|
class |
SlidingResultsAssembler
Assembler which determines whether results can be ignored under the current
context then "slides" past results not within the given range, avoiding the
overhead of assembling a graph.
|
class |
StreamingResultsAssembler
Assembler which determines whether results can be ignored under the current
context then "slides" past results not within the given range, avoiding the
overhead of assembling a graph.
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
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.