Class ControlledWorkerBindLeftJoin
- java.lang.Object
-
- org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E>
-
- org.eclipse.rdf4j.common.iteration.LookAheadIteration<T>
-
- org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase<T>
-
- org.eclipse.rdf4j.federated.evaluation.join.JoinExecutorBase<BindingSet>
-
- org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindJoinBase
-
- org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindLeftJoin
-
- All Implemented Interfaces:
AutoCloseable
,Runnable
,Iterator<BindingSet>
,CloseableIteration<BindingSet>
,ParallelExecutor<BindingSet>
public class ControlledWorkerBindLeftJoin extends ControlledWorkerBindJoinBase
Bind join implementation for left joins (i.e., OPTIOAL clauses)- Author:
- Andreas Schwarte
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
ControlledWorkerBindLeftJoin.EmptyLeftBoundJoinTaskCreator
protected static class
ControlledWorkerBindLeftJoin.LeftBoundJoinTaskCreator
-
Nested classes/interfaces inherited from class org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindJoinBase
ControlledWorkerBindJoinBase.TaskCreator
-
-
Field Summary
-
Fields inherited from class org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindJoinBase
phaser, scheduler
-
Fields inherited from class org.eclipse.rdf4j.federated.evaluation.join.JoinExecutorBase
bindings, joinVars, leftIter, rightArg
-
Fields inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
evaluationThread, executorId, finished, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy
-
-
Constructor Summary
Constructors Constructor Description ControlledWorkerBindLeftJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ControlledWorkerBindJoinBase.TaskCreator
determineTaskCreator(TupleExpr expr, BindingSet bs)
Return theControlledWorkerBindJoinBase.TaskCreator
for executing the bind join-
Methods inherited from class org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindJoinBase
getNextBindJoinSize, handleBindings, handleClose
-
Methods inherited from class org.eclipse.rdf4j.federated.evaluation.join.JoinExecutorBase
getExecutorType, getJoinVars, performExecution, setJoinVars
-
Methods inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toString
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, remove
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosed
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
stream
-
Methods inherited from interface java.util.Iterator
forEachRemaining
-
-
-
-
Constructor Detail
-
ControlledWorkerBindLeftJoin
public ControlledWorkerBindLeftJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
-
Method Detail
-
determineTaskCreator
protected ControlledWorkerBindJoinBase.TaskCreator determineTaskCreator(TupleExpr expr, BindingSet bs)
Description copied from class:ControlledWorkerBindJoinBase
Return theControlledWorkerBindJoinBase.TaskCreator
for executing the bind join- Specified by:
determineTaskCreator
in classControlledWorkerBindJoinBase
- Returns:
-
-