Uses of Interface
org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutor

Packages that use ParallelExecutor

Package	Description
org.eclipse.rdf4j.federated.evaluation.concurrent
org.eclipse.rdf4j.federated.evaluation.join
org.eclipse.rdf4j.federated.evaluation.union
org.eclipse.rdf4j.federated.optimizer

Uses of ParallelExecutor in org.eclipse.rdf4j.federated.evaluation.concurrent

Classes in org.eclipse.rdf4j.federated.evaluation.concurrent that implement ParallelExecutor

Modifier and Type	Class	Description
class	ParallelExecutorBase<T>	Base class for common parallel executors such as JoinExecutorBase and UnionExecutorBase.
class	ParallelServiceExecutor	Parallel executor for FedXService nodes, which wrap SERVICE expressions.

Methods in org.eclipse.rdf4j.federated.evaluation.concurrent that return ParallelExecutor

Modifier and Type	Method	Description
ParallelExecutor<T>	ParallelTask.getControl()	return the controlling instance, e.g.

Methods in org.eclipse.rdf4j.federated.evaluation.concurrent with parameters of type ParallelExecutor

Modifier and Type	Method	Description
void	ControlledWorkerScheduler.informFinish(ParallelExecutor<T> control)	Inform this scheduler that the specified control instance will no longer submit tasks.
boolean	ControlledWorkerScheduler.isRunning(ParallelExecutor<T> control)	Determine if there are still task running or queued for the specified control.
void	ControlledWorkerScheduler.scheduleAll(List<ParallelTask<T>> tasks, ParallelExecutor<T> control)	Schedule the given tasks and inform about finish using the same lock, i.e.

Uses of ParallelExecutor in org.eclipse.rdf4j.federated.evaluation.join

Classes in org.eclipse.rdf4j.federated.evaluation.join that implement ParallelExecutor

Modifier and Type	Class	Description
class	ControlledWorkerBindJoin	Execution of a regular join as bind join.
class	ControlledWorkerBindJoinBase	Base class for executing joins as bind joins (i.e., the bindings of a block are injected in the SPARQL query as VALUES clause).
class	ControlledWorkerBindLeftJoin	Bind join implementation for left joins (i.e., OPTIOAL clauses)
class	ControlledWorkerBoundJoin	Deprecated, for removal: This API element is subject to removal in a future version. replaced with ControlledWorkerBindJoinl
class	ControlledWorkerJoin	Execute the nested loop join in an asynchronous fashion, i.e.
class	ControlledWorkerLeftJoin	Execute the nested loop join in an asynchronous fashion, i.e.
class	HashJoin	Operator for a hash join of tuple expressions.
class	JoinExecutorBase<T>	Base class for any join parallel join executor.
class	SynchronousBoundJoin	Execute the nested loop join in a synchronous fashion, using grouped requests, i.e.
class	SynchronousJoin	Execute the nested loop join in a synchronous fashion, i.e.

Fields in org.eclipse.rdf4j.federated.evaluation.join declared as ParallelExecutor

Modifier and Type	Field	Description
protected final ParallelExecutor<BindingSet>	ParallelBindLeftJoinTask.joinControl
protected final ParallelExecutor<BindingSet>	ParallelBoundJoinTask.joinControl
protected final ParallelExecutor<BindingSet>	ParallelCheckJoinTask.joinControl	Deprecated, for removal: This API element is subject to removal in a future version.
protected final ParallelExecutor<BindingSet>	ParallelEmptyBindLeftJoinTask.joinControl
protected final ParallelExecutor<BindingSet>	ParallelJoinTask.joinControl
protected final ParallelExecutor<BindingSet>	ParallelLeftJoinTask.joinControl
protected final ParallelExecutor<BindingSet>	ParallelServiceJoinTask.joinControl

Methods in org.eclipse.rdf4j.federated.evaluation.join that return ParallelExecutor

Modifier and Type	Method	Description
ParallelExecutor<BindingSet>	ParallelBindLeftJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelBoundJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelCheckJoinTask.getControl()	Deprecated, for removal: This API element is subject to removal in a future version.
ParallelExecutor<BindingSet>	ParallelEmptyBindLeftJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelLeftJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelServiceJoinTask.getControl()

Methods in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ParallelExecutor

Modifier and Type	Method	Description
ParallelTask<BindingSet>	ControlledWorkerBindJoin.BoundJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBindJoin.CheckJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)	Deprecated, for removal: This API element is subject to removal in a future version.
ParallelTask<BindingSet>	ControlledWorkerBindJoin.FedXServiceJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBindJoinBase.TaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBindLeftJoin.EmptyLeftBoundJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBindLeftJoin.LeftBoundJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBoundJoin.BoundJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBoundJoin.CheckJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBoundJoin.FedXServiceJoinTaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)
ParallelTask<BindingSet>	ControlledWorkerBoundJoin.TaskCreator.getTask(ParallelExecutor<BindingSet> control, List<BindingSet> bindings)

Constructors in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ParallelExecutor

Modifier	Constructor	Description
	ParallelBindLeftJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, StatementTupleExpr expr, List<BindingSet> bindings)
	ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, StatementTupleExpr expr, List<BindingSet> bindings)
	ParallelCheckJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, CheckStatementPattern expr, List<BindingSet> bindings)	Deprecated, for removal: This API element is subject to removal in a future version.
	ParallelEmptyBindLeftJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, EmptyStatementPattern expr, List<BindingSet> bindings)
	ParallelJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, TupleExpr expr, BindingSet bindings)
	ParallelLeftJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, LeftJoin join, BindingSet leftBindings)
	ParallelServiceJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, FedXService expr, List<BindingSet> bindings)

Uses of ParallelExecutor in org.eclipse.rdf4j.federated.evaluation.union

Classes in org.eclipse.rdf4j.federated.evaluation.union that implement ParallelExecutor

Modifier and Type	Class	Description
class	ControlledWorkerUnion<T>	Execution of union tasks with ControlledWorkerScheduler.
class	SynchronousWorkerUnion<T>	Synchronous execution of union tasks, i.e.
class	UnionExecutorBase<T>	Base class for any parallel union executor.
class	WorkerUnionBase<T>	Base class for worker unions providing convenience functions to add tasks.

Fields in org.eclipse.rdf4j.federated.evaluation.union declared as ParallelExecutor

Modifier and Type	Field	Description
protected final ParallelExecutor<Statement>	ParallelGetStatementsTask.unionControl
protected final ParallelExecutor<BindingSet>	ParallelPreparedAlgebraUnionTask.unionControl
protected final ParallelExecutor<BindingSet>	ParallelPreparedUnionTask.unionControl
protected final ParallelExecutor<BindingSet>	ParallelUnionOperatorTask.unionControl
protected final ParallelExecutor<BindingSet>	ParallelUnionTask.unionControl

Methods in org.eclipse.rdf4j.federated.evaluation.union that return ParallelExecutor

Modifier and Type	Method	Description
ParallelExecutor<Statement>	ParallelGetStatementsTask.getControl()
ParallelExecutor<BindingSet>	ParallelPreparedAlgebraUnionTask.getControl()
ParallelExecutor<BindingSet>	ParallelPreparedUnionTask.getControl()
ParallelExecutor<BindingSet>	ParallelUnionOperatorTask.getControl()
ParallelExecutor<BindingSet>	ParallelUnionTask.getControl()

Constructors in org.eclipse.rdf4j.federated.evaluation.union with parameters of type ParallelExecutor

Modifier	Constructor	Description
	ParallelGetStatementsTask(ParallelExecutor<Statement> unionControl, Endpoint endpoint, Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
	ParallelPreparedAlgebraUnionTask(ParallelExecutor<BindingSet> unionControl, TupleExpr preparedQuery, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
	ParallelPreparedUnionTask(ParallelExecutor<BindingSet> unionControl, String preparedQuery, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
	ParallelUnionOperatorTask(ParallelExecutor<BindingSet> unionControl, QueryEvaluationStep expr, BindingSet bindings)
	ParallelUnionTask(ParallelExecutor<BindingSet> unionControl, StatementPattern stmt, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)

Uses of ParallelExecutor in org.eclipse.rdf4j.federated.optimizer

Classes in org.eclipse.rdf4j.federated.optimizer that implement ParallelExecutor

Modifier and Type	Class	Description
protected static class	SourceSelection.SourceSelectionExecutorWithLatch

Methods in org.eclipse.rdf4j.federated.optimizer that return ParallelExecutor

Modifier and Type	Method	Description
ParallelExecutor<BindingSet>	SourceSelection.ParallelCheckTask.getControl()