org.cloudgraph.hbase.service

Class GraphStreamQuery

java.lang.Object

org.cloudgraph.hbase.service.GraphQuery

org.cloudgraph.hbase.service.GraphStreamQuery

All Implemented Interfaces:

io.reactivex.ObservableOnSubscribe<commonj.sdo.DataGraph>, org.plasma.sdo.access.QueryDispatcher, org.plasma.sdo.access.StreamQueryDispatcher

public class GraphStreamQuery
extends GraphQuery
implements io.reactivex.ObservableOnSubscribe<commonj.sdo.DataGraph>, org.plasma.sdo.access.StreamQueryDispatcher

Field Summary

Fields inherited from class org.cloudgraph.hbase.service.GraphQuery

context

Constructor Summary

Constructors

Constructor and Description
GraphStreamQuery(ServiceContext context)

Method Summary

Modifier and Type	Method and Description
void	close()
protected ResultsAssembler	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	execute(org.apache.hadoop.hbase.client.Scan scan, TableReader rootTableReader, ResultsAssembler collector)
protected void	executeAsStream(org.plasma.query.model.Query query, org.plasma.query.collector.SelectionCollector selection, org.plasma.sdo.PlasmaType type, org.apache.hadoop.hbase.filter.Filter columnFilter, Expr whereSyntaxTree, ResultsComparator orderingComparator, List<PartialRowKey> partialScans, List<FuzzyRowKey> fuzzyScans, List<CompleteRowKey> completeKeys, Timestamp snapshotDate)
io.reactivex.Observable<commonj.sdo.DataGraph>	findAsStream(org.plasma.query.model.Query query, int requestMax, Timestamp snapshotDate)
io.reactivex.Observable<commonj.sdo.DataGraph>	findAsStream(org.plasma.query.model.Query query, Timestamp snapshotDate)
void	subscribe(io.reactivex.ObservableEmitter<commonj.sdo.DataGraph> emitter)

Methods inherited from class org.cloudgraph.hbase.service.GraphQuery

canAbortScan, collectRowKeyProperties, count, createRootColumnFilterAssembler, createScan, createScan, execute, execute, execute, execute, execute, execute, execute, find, find, getVariables, log, serializeGraph

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GraphStreamQuery

public GraphStreamQuery(ServiceContext context)

Method Detail

close

public void close()

Specified by:

close in interface org.plasma.sdo.access.QueryDispatcher

Specified by:

close in interface org.plasma.sdo.access.StreamQueryDispatcher

Overrides:

close in class GraphQuery

findAsStream

public io.reactivex.Observable<commonj.sdo.DataGraph> findAsStream(org.plasma.query.model.Query query,
                                                                   Timestamp snapshotDate)

Specified by:

findAsStream in interface org.plasma.sdo.access.StreamQueryDispatcher

findAsStream

public io.reactivex.Observable<commonj.sdo.DataGraph> findAsStream(org.plasma.query.model.Query query,
                                                                   int requestMax,
                                                                   Timestamp snapshotDate)

Specified by:

findAsStream in interface org.plasma.sdo.access.StreamQueryDispatcher

subscribe

public void subscribe(io.reactivex.ObservableEmitter<commonj.sdo.DataGraph> emitter)
               throws Exception

Specified by:

subscribe in interface io.reactivex.ObservableOnSubscribe<commonj.sdo.DataGraph>

Throws:

Exception

executeAsStream

protected void executeAsStream(org.plasma.query.model.Query query,
                               org.plasma.query.collector.SelectionCollector selection,
                               org.plasma.sdo.PlasmaType type,
                               org.apache.hadoop.hbase.filter.Filter columnFilter,
                               Expr whereSyntaxTree,
                               ResultsComparator orderingComparator,
                               List<PartialRowKey> partialScans,
                               List<FuzzyRowKey> fuzzyScans,
                               List<CompleteRowKey> completeKeys,
                               Timestamp snapshotDate)

execute

protected void execute(org.apache.hadoop.hbase.client.Scan scan,
                       TableReader rootTableReader,
                       ResultsAssembler collector)
                throws IOException

Overrides:

execute in class GraphQuery

Throws:

IOException

createResultsAssembler

protected ResultsAssembler 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)

Overrides:

createResultsAssembler in class GraphQuery