Class ParallelBoundJoinTask

java.lang.Object

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

org.eclipse.rdf4j.federated.evaluation.join.ParallelBoundJoinTask

All Implemented Interfaces:

ParallelTask<BindingSet>

public class ParallelBoundJoinTask
extends ParallelTaskBase<BindingSet>

A task implementation representing a bound join, see FederationEvalStrategy.evaluateBoundJoinStatementPattern(StatementTupleExpr, List) for further details on the evaluation process.

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<BindingSet>	bindings
protected final StatementTupleExpr	expr
protected final ParallelExecutor<BindingSet>	joinControl
protected final FederationEvalStrategy	strategy

Fields inherited from class ParallelTaskBase

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, StatementTupleExpr expr, List<BindingSet> bindings)

Method Summary

Modifier and Type	Method	Description
ParallelExecutor<BindingSet>	getControl()	return the controlling instance, e.g. in most cases the instance of a thread.
protected CloseableIteration<BindingSet>	performTaskInternal()

Methods inherited from class ParallelTaskBase

cancel, close, performTask, setScheduledFuture, toString

Methods inherited from class Object

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

Methods inherited from interface ParallelTask

getQueryInfo

Field Details

strategy

protected final FederationEvalStrategy strategy

expr

protected final StatementTupleExpr expr

bindings

protected final List<BindingSet> bindings

joinControl

protected final ParallelExecutor<BindingSet> joinControl

Constructor Details

ParallelBoundJoinTask

public ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl,
 FederationEvalStrategy strategy,
 StatementTupleExpr expr,
 List<BindingSet> bindings)

Method Details

performTaskInternal

protected CloseableIteration<BindingSet> performTaskInternal()
                                                      throws Exception

Specified by:

performTaskInternal in class ParallelTaskBase<BindingSet>

Throws:

Exception

getControl

public ParallelExecutor<BindingSet> getControl()

Description copied from interface: ParallelTask

return the controlling instance, e.g. in most cases the instance of a thread. Shared variables are used to inform the thread about new events.

Returns:

the control executor