Class JoinExecutorBase<T>

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<T, QueryEvaluationException>

org.eclipse.rdf4j.common.iteration.LookAheadIteration<T, QueryEvaluationException>

org.eclipse.rdf4j.repository.sparql.federation.JoinExecutorBase<T>

org.eclipse.rdf4j.query.algebra.evaluation.federation.JoinExecutorBase<T>

All Implemented Interfaces:

AutoCloseable, CloseableIteration<T, QueryEvaluationException>, Iteration<T, QueryEvaluationException>

Direct Known Subclasses:

ServiceJoinIterator

@Deprecated(since="2.3")
public abstract class JoinExecutorBase<T>
extends JoinExecutorBase<T>

Deprecated.

Use JoinExecutorBase

Base class for any join parallel join executor. Note that this class extends LookAheadIteration and thus any implementation of this class is applicable for pipelining when used in a different thread (access to shared variables is synchronized).

Field Summary

Fields inherited from class JoinExecutorBase

bindings, closed, finished, leftIter, NEXT_JOIN_ID, rightArg, rightIter, rightQueue

Constructor Summary

Constructors

Constructor	Description
JoinExecutorBase(CloseableIteration<T, QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings)	Deprecated.

Method Summary

Methods inherited from class JoinExecutorBase

addResult, done, getNextElement, handleBindings, handleClose, isFinished, run, toss

Methods inherited from class LookAheadIteration

hasNext, next, remove

Methods inherited from class AbstractCloseableIteration

close, isClosed

Methods inherited from class Object

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

Methods inherited from interface CloseableIteration

stream

Constructor Details

JoinExecutorBase

public JoinExecutorBase(CloseableIteration<T, QueryEvaluationException> leftIter,
 TupleExpr rightArg,
 BindingSet bindings)
                 throws QueryEvaluationException

Deprecated.

Throws:

QueryEvaluationException