org.cloudgraph.hbase.results

Class ParallelSlidingResultsAssembler

java.lang.Object

org.cloudgraph.hbase.results.DefaultResultsAssembler

org.cloudgraph.hbase.results.ParallelSlidingResultsAssembler

All Implemented Interfaces:

ResultsAssembler, ResultsSlider

public class ParallelSlidingResultsAssembler
extends DefaultResultsAssembler
implements ResultsAssembler

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.

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:

1.0.7

Author:

Scott Cinnamond

See Also:

GraphAssemblerCallable, HBaseGraphAssembler, Expr, GraphRecognizerContext, GraphAssemblerFactory, Future

Field Summary

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
ParallelSlidingResultsAssembler(Expr graphRecognizerRootExpr, Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator, TableReader rootTableReader, GraphAssemblerFactory assemblerFactory, Integer startRange, Integer endRange, ThreadPoolMappingProps poolProps)

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

Constructor Detail

ParallelSlidingResultsAssembler

public ParallelSlidingResultsAssembler(Expr graphRecognizerRootExpr,
                                       Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
                                       TableReader rootTableReader,
                                       GraphAssemblerFactory assemblerFactory,
                                       Integer startRange,
                                       Integer endRange,
                                       ThreadPoolMappingProps poolProps)

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