org.cloudgraph.hbase.results

Class ResultsAggregator

java.lang.Object

org.cloudgraph.hbase.results.DefaultResultsAssembler

org.cloudgraph.hbase.results.ResultsAggregator

All Implemented Interfaces:

ResultsAssembler, ResultsSlider

public class ResultsAggregator
extends DefaultResultsAssembler
implements ResultsAssembler

Assembler which executes aggregate functions, grouping and having clause syntax tree evaluation.

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.

Since:

1.1.4

Author:

Scott Cinnamond

See Also:

FunctionPath, Expr, GraphRecognizerContext

Field Summary

Fields

Modifier and Type	Field and Description
protected org.plasma.sdo.PlasmaDataGraph	current
protected Collection<org.plasma.query.collector.FunctionPath>	funcPaths
protected HBaseGraphAssembler	graphAssembler
protected Map<org.plasma.sdo.PlasmaDataGraph,org.plasma.sdo.PlasmaDataGraph>	graphs
protected ResultsComparator	groupingComparator
protected GraphRecognizerContext	havingContext
protected Expr	havingSyntaxTree
protected List<org.plasma.sdo.PlasmaDataGraph>	result
protected org.plasma.query.collector.Selection	selection

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
ResultsAggregator(org.plasma.query.collector.Selection selection, Expr whereSyntaxTree, ResultsComparator orderingComparator, ResultsComparator groupingComparator, Expr havingSyntaxTree, 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

graphs

protected Map<org.plasma.sdo.PlasmaDataGraph,org.plasma.sdo.PlasmaDataGraph> graphs

current

protected org.plasma.sdo.PlasmaDataGraph current

selection

protected org.plasma.query.collector.Selection selection

funcPaths

protected Collection<org.plasma.query.collector.FunctionPath> funcPaths

havingSyntaxTree

protected Expr havingSyntaxTree

havingContext

protected GraphRecognizerContext havingContext

groupingComparator

protected ResultsComparator groupingComparator

result

protected List<org.plasma.sdo.PlasmaDataGraph> result

Constructor Detail

ResultsAggregator

public ResultsAggregator(org.plasma.query.collector.Selection selection,
                         Expr whereSyntaxTree,
                         ResultsComparator orderingComparator,
                         ResultsComparator groupingComparator,
                         Expr havingSyntaxTree,
                         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