Class ControlledWorkerBindJoin
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.ControlledWorkerBindJoin
- All Implemented Interfaces:
AutoCloseable,Runnable,Iterator<BindingSet>,CloseableIteration<BindingSet>,ParallelExecutor<BindingSet>
Execution of a regular join as bind join.
- Author:
- Andreas Schwarte
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected classprotected classDeprecated, for removal: This API element is subject to removal in a future version.protected classNested 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, schedulerFields inherited from class org.eclipse.rdf4j.federated.evaluation.join.JoinExecutorBase
bindings, joinVars, leftIter, rightArgFields inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
evaluationThread, executorId, finished, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy -
Constructor Summary
ConstructorsConstructorDescriptionControlledWorkerBindJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) -
Method Summary
Modifier and TypeMethodDescriptionprotected ControlledWorkerBindJoinBase.TaskCreatordetermineTaskCreator(TupleExpr expr, BindingSet bs) Return theControlledWorkerBindJoinBase.TaskCreatorfor executing the bind joinMethods inherited from class org.eclipse.rdf4j.federated.evaluation.join.ControlledWorkerBindJoinBase
getNextBindJoinSize, handleBindings, handleCloseMethods inherited from class org.eclipse.rdf4j.federated.evaluation.join.JoinExecutorBase
getExecutorType, getJoinVars, performExecution, setJoinVarsMethods inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toStringMethods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, removeMethods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosedMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
streamMethods inherited from interface java.util.Iterator
forEachRemaining
-
Constructor Details
-
ControlledWorkerBindJoin
public ControlledWorkerBindJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) throws QueryEvaluationException - Throws:
QueryEvaluationException
-
-
Method Details
-
determineTaskCreator
protected ControlledWorkerBindJoinBase.TaskCreator determineTaskCreator(TupleExpr expr, BindingSet bs) Description copied from class:ControlledWorkerBindJoinBaseReturn theControlledWorkerBindJoinBase.TaskCreatorfor executing the bind join- Specified by:
determineTaskCreatorin classControlledWorkerBindJoinBase- Returns:
-