Package org.eclipse.rdf4j.federated.evaluation.join

Class ControlledWorkerBindJoin

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<BindingSet>

org.eclipse.rdf4j.common.iteration.LookAheadIteration<BindingSet>

org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase<BindingSet>

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>

public class ControlledWorkerBindJoin
extends ControlledWorkerBindJoinBase

Execution of a regular join as bind join.

Author:

Andreas Schwarte

See Also:

• ControlledWorkerBindJoinBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ControlledWorkerBindJoin.BoundJoinTaskCreator
protected class	ControlledWorkerBindJoin.CheckJoinTaskCreator	Deprecated, for removal: This API element is subject to removal in a future version.
protected class	ControlledWorkerBindJoin.FedXServiceJoinTaskCreator

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
ControlledWorkerBindJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)

Method Summary

Modifier and Type	Method	Description
protected ControlledWorkerBindJoinBase.TaskCreator	determineTaskCreator(TupleExpr expr, BindingSet bs)	Return the ControlledWorkerBindJoinBase.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 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: ControlledWorkerBindJoinBase

Return the ControlledWorkerBindJoinBase.TaskCreator for executing the bind join

Specified by:

determineTaskCreator in class ControlledWorkerBindJoinBase

Parameters:

expr -

bs -

Returns: