org.openrdf.sail.federation.evaluation
Class ParallelJoinCursor

java.lang.Object
  info.aduna.iteration.CloseableIterationBase<E,X>
      info.aduna.iteration.LookAheadIteration<BindingSet,QueryEvaluationException>
          org.openrdf.sail.federation.evaluation.ParallelJoinCursor

All Implemented Interfaces:

CloseableIteration<BindingSet,QueryEvaluationException>, Iteration<BindingSet,QueryEvaluationException>, Runnable

public class ParallelJoinCursor
extends LookAheadIteration<BindingSet,QueryEvaluationException>
implements Runnable

Iterate the left side and evaluate the right side in separate thread, only iterate the right side in the controlling thread.

Author:

James Leigh

Constructor Summary

ParallelJoinCursor(EvaluationStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings)

Method Summary

BindingSet	getNextElement()
void	handleClose()
void	run()
String	toString()

Methods inherited from class info.aduna.iteration.LookAheadIteration

hasNext, next, remove

Methods inherited from class info.aduna.iteration.CloseableIterationBase

close, isClosed

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelJoinCursor

public ParallelJoinCursor(EvaluationStrategy strategy,
                          CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
                          TupleExpr rightArg,
                          BindingSet bindings)
                   throws QueryEvaluationException

Throws:

QueryEvaluationException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getNextElement

public BindingSet getNextElement()
                          throws QueryEvaluationException

Specified by:

getNextElement in class LookAheadIteration<BindingSet,QueryEvaluationException>

Throws:

QueryEvaluationException

handleClose

public void handleClose()
                 throws QueryEvaluationException

Overrides:

handleClose in class LookAheadIteration<BindingSet,QueryEvaluationException>

Throws:

QueryEvaluationException

toString

public String toString()

Overrides:

toString in class Object