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 ControlledWorkerBindJoinBase

ControlledWorkerBindJoinBase.TaskCreator

Modifier and Type	Class	Description
protected static interface	ControlledWorkerBindJoinBase.TaskCreator

Field Summary

Fields inherited from class ControlledWorkerBindJoinBase

phaser, scheduler

Modifier and Type	Field	Description
protected final Phaser	phaser
protected final ControlledWorkerScheduler<BindingSet>	scheduler

Fields inherited from class JoinExecutorBase

bindings, joinVars, leftIter, rightArg

Modifier and Type	Field	Description
protected final BindingSet	bindings
protected Set<String>	joinVars
protected CloseableIteration<BindingSet>	leftIter
protected final TupleExpr	rightArg

Fields inherited from class ParallelExecutorBase

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

Modifier and Type	Field	Description
protected Thread	evaluationThread
protected final long	executorId
protected boolean	finished
protected static final AtomicLong	NEXT_EXECUTOR_ID
protected final QueryInfo	queryInfo
protected CloseableIteration<BindingSet>	rightIter
protected FedXQueueCursor<BindingSet>	rightQueue
protected final FederationEvalStrategy	strategy

Fields inherited from interface CloseableIteration

EMPTY_STATEMENT_ITERATION

Modifier and Type	Field	Description
static final EmptyIteration<Statement>	EMPTY_STATEMENT_ITERATION

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 ControlledWorkerBindJoinBase

getNextBindJoinSize, handleBindings, handleClose

Modifier and Type	Method	Description
protected int	getNextBindJoinSize(int configuredBindJoinSize, int totalBindings)	Return the size of the next bind join block.
protected void	handleBindings()	Implementations must implement this method to handle bindings.
void	handleClose()	Called by AbstractCloseableIteration.close() when it is called for the first time.

Methods inherited from class JoinExecutorBase

getExecutorType, getJoinVars, performExecution, setJoinVars

Modifier and Type	Method	Description
protected String	getExecutorType()
Set<String>	getJoinVars()
protected final void	performExecution()	Perform the parallel execution.
void	setJoinVars(Set<String> joinVars)	Set the join variables

Methods inherited from class ParallelExecutorBase

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

Modifier and Type	Method	Description
void	addResult(CloseableIteration<BindingSet> res)	Handle the result appropriately, e.g. add it to the result iteration.
protected void	checkTimeout()	Checks whether the query execution has run into a timeout.
void	done()	Inform the controlling instance that some job is done from a different thread.
String	getDisplayId()
protected String	getId()
BindingSet	getNextElement()	Gets the next element.
QueryInfo	getQueryInfo()	Return the query info of the associated query
boolean	isFinished()	Return true if this executor is finished or aborted
final void	run()
void	toss(Exception e)	Toss some exception to the controlling instance
String	toString()

Methods inherited from class LookAheadIteration

hasNext, next, remove

Modifier and Type	Method	Description
final boolean	hasNext()
final BindingSet	next()
void	remove()	Throws an UnsupportedOperationException.

Methods inherited from class AbstractCloseableIteration

close, isClosed

Modifier and Type	Method	Description
final void	close()	Calls AbstractCloseableIteration.handleClose() upon first call and makes sure the resource closures are only executed once.
final boolean	isClosed()	Checks whether this CloseableIteration has been closed.

Methods inherited from class Object

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

Methods inherited from interface CloseableIteration

stream

Modifier and Type	Method	Description
default Stream<BindingSet>	stream()	Convert the results to a Java 8 Stream.

Methods inherited from interface 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: