org.cloudgraph.hbase.results

Class StreamingResultsAssembler

java.lang.Object

org.cloudgraph.hbase.results.DefaultResultsAssembler

org.cloudgraph.hbase.results.StreamingResultsAssembler

All Implemented Interfaces:

ResultsAssembler, ResultsSlider

public class StreamingResultsAssembler
extends DefaultResultsAssembler
implements ResultsAssembler

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. When a graph recognizer is present for the current context, no result can be bypassed as the recognizer requires an assembled graph to evaluate and make its determination.

Since:

0.5.9

Author:

Scott Cinnamond

See Also:

HBaseGraphAssembler, Expr, GraphRecognizerContext

Field Summary

Fields

Modifier and Type	Field and Description
protected org.plasma.sdo.PlasmaDataGraph	graph
protected HBaseGraphAssembler	graphAssembler

Fields inherited from class org.cloudgraph.hbase.results.DefaultResultsAssembler

endRange, ignoredResults, ignoredResultsPreceedingRange, orderingComparator, range, resultEndRangeReached, rootTableReader, startRange, unrecognizedResults, whereContext, whereSyntaxTree

Constructor Summary

Constructors

Constructor and Description
StreamingResultsAssembler(Expr graphRecognizerRootExpr, Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator, TableReader rootTableReader, HBaseGraphAssembler graphAssembler, Integer startRange, Integer endRange)

Method Summary

Modifier and Type	Method and Description
boolean	collect(org.apache.hadoop.hbase.client.Result resultRow) Determines whether the given row is to be added to the underlying collection returning true if the given row is added and false if the given row is not added.
org.plasma.sdo.PlasmaDataGraph	getCurrentResult()
org.plasma.sdo.PlasmaDataGraph[]	getResults() Returns results
int	size() Returns the current size of the collection

Methods inherited from class org.cloudgraph.hbase.results.DefaultResultsAssembler

canIgnoreResults, currentResultIgnored, getIgnoredResults, getUnrecognizedResults, hasRange, isResultEndRangeReached, serializeGraph

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cloudgraph.hbase.results.ResultsSlider

canIgnoreResults, currentResultIgnored, getIgnoredResults, getUnrecognizedResults, isResultEndRangeReached

Field Detail

graphAssembler

protected HBaseGraphAssembler graphAssembler

graph

protected org.plasma.sdo.PlasmaDataGraph graph

Constructor Detail

StreamingResultsAssembler

public StreamingResultsAssembler(Expr graphRecognizerRootExpr,
                                 Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
                                 TableReader rootTableReader,
                                 HBaseGraphAssembler graphAssembler,
                                 Integer startRange,
                                 Integer endRange)

Method Detail

collect

public boolean collect(org.apache.hadoop.hbase.client.Result resultRow)
                throws IOException

Description copied from interface: ResultsAssembler

Determines whether the given row is to be added to the underlying collection returning true if the given row is added and false if the given row is not added.

Specified by:

collect in interface ResultsAssembler

Parameters:

resultRow - the row

Returns:

true if the given row is added and false if the given row is not added.

Throws:

IOException

size

public int size()

Description copied from interface: ResultsAssembler

Returns the current size of the collection

Specified by:

size in interface ResultsAssembler

Returns:

the current size of the collection

getResults

public org.plasma.sdo.PlasmaDataGraph[] getResults()

Description copied from interface: ResultsAssembler

Returns results

Specified by:

getResults in interface ResultsAssembler

Returns:

getCurrentResult

public org.plasma.sdo.PlasmaDataGraph getCurrentResult()

Specified by:

getCurrentResult in interface ResultsAssembler