Class ControlledWorkerBindLeftJoin

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.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 ControlledWorkerBindJoinBase

ControlledWorkerBindJoinBase.TaskCreator

Field Summary

Fields inherited from class ControlledWorkerBindJoinBase

phaser, scheduler

Fields inherited from class JoinExecutorBase

bindings, joinVars, leftIter, rightArg

Fields inherited from class ParallelExecutorBase

evaluationThread, executorId, finished, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy

Fields inherited from interface CloseableIteration

EMPTY_STATEMENT_ITERATION

Constructor Summary

Constructors

Constructor	Description
ControlledWorkerBindLeftJoin(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 ControlledWorkerBindJoinBase

getNextBindJoinSize, handleBindings, handleClose

Methods inherited from class JoinExecutorBase

getExecutorType, getJoinVars, performExecution, setJoinVars

Methods inherited from class ParallelExecutorBase

addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toString

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, wait, wait, wait

Methods inherited from interface CloseableIteration

stream

Methods inherited from interface Iterator

forEachRemaining

Constructor Details

ControlledWorkerBindLeftJoin

public ControlledWorkerBindLeftJoin(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: