org.cloudgraph.hbase.results

Class DefaultResultsAssembler

java.lang.Object

org.cloudgraph.hbase.results.DefaultResultsAssembler

All Implemented Interfaces:

ResultsAssembler, ResultsSlider

Direct Known Subclasses:

ParallelSlidingResultsAssembler, ResultsAggregator, SlidingResultsAssembler, StreamingResultsAssembler

public abstract class DefaultResultsAssembler
extends Object
implements ResultsAssembler

Default functionality for various results assemblers.

Since:

1.0.7

Author:

Scott Cinnamond

See Also:

Expr, GraphRecognizerContext

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	endRange
protected int	ignoredResults
protected int	ignoredResultsPreceedingRange
protected Comparator<org.plasma.sdo.PlasmaDataGraph>	orderingComparator
protected int	range
protected boolean	resultEndRangeReached
protected TableReader	rootTableReader
protected Integer	startRange
protected int	unrecognizedResults
protected GraphRecognizerContext	whereContext
protected Expr	whereSyntaxTree

Constructor Summary

Constructors

Constructor and Description
DefaultResultsAssembler(Expr whereSyntaxTree, Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator, TableReader rootTableReader, Integer startRange, Integer endRange)

Method Summary

Modifier and Type	Method and Description
boolean	canIgnoreResults() Returns whether results may be ignored under the current context.
boolean	currentResultIgnored()
int	getIgnoredResults()
int	getUnrecognizedResults()
protected boolean	hasRange()
boolean	isResultEndRangeReached()
protected String	serializeGraph(commonj.sdo.DataGraph graph)

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.ResultsAssembler

collect, getCurrentResult, getResults, size

Field Detail

whereSyntaxTree

protected Expr whereSyntaxTree

whereContext

protected GraphRecognizerContext whereContext

orderingComparator

protected Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator

rootTableReader

protected TableReader rootTableReader

startRange

protected Integer startRange

endRange

protected Integer endRange

resultEndRangeReached

protected boolean resultEndRangeReached

unrecognizedResults

protected int unrecognizedResults

ignoredResults

protected int ignoredResults

ignoredResultsPreceedingRange

protected int ignoredResultsPreceedingRange

range

protected int range

Constructor Detail

DefaultResultsAssembler

public DefaultResultsAssembler(Expr whereSyntaxTree,
                               Comparator<org.plasma.sdo.PlasmaDataGraph> orderingComparator,
                               TableReader rootTableReader,
                               Integer startRange,
                               Integer endRange)

Method Detail

hasRange

protected boolean hasRange()

getUnrecognizedResults

public int getUnrecognizedResults()

Specified by:

getUnrecognizedResults in interface ResultsSlider

getIgnoredResults

public int getIgnoredResults()

Specified by:

getIgnoredResults in interface ResultsSlider

isResultEndRangeReached

public boolean isResultEndRangeReached()

Specified by:

isResultEndRangeReached in interface ResultsSlider

canIgnoreResults

public boolean canIgnoreResults()

Description copied from interface: ResultsSlider

Returns whether results may be ignored under the current context.

Specified by:

canIgnoreResults in interface ResultsSlider

Returns:

whether results may be ignored under the current context.

currentResultIgnored

public boolean currentResultIgnored()

Specified by:

currentResultIgnored in interface ResultsSlider

serializeGraph

protected String serializeGraph(commonj.sdo.DataGraph graph)