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 and 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 and 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 and 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 and Description
class	ControlledWorkerBoundJoin Execute the nested loop join in an asynchronous fashion, using grouped requests, i.e.
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 and Description
protected ParallelExecutor<BindingSet>	ParallelJoinTask.joinControl
protected ParallelExecutor<BindingSet>	ParallelLeftJoinTask.joinControl
protected ParallelExecutor<BindingSet>	ParallelServiceJoinTask.joinControl
protected ParallelExecutor<BindingSet>	ParallelBoundJoinTask.joinControl
protected ParallelExecutor<BindingSet>	ParallelCheckJoinTask.joinControl

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

Modifier and Type	Method and Description
ParallelExecutor<BindingSet>	ParallelJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelLeftJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelServiceJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelBoundJoinTask.getControl()
ParallelExecutor<BindingSet>	ParallelCheckJoinTask.getControl()

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

Modifier and Type	Method and Description
ParallelTask<BindingSet>	ControlledWorkerBoundJoin.TaskCreator.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)

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

Constructor and Description
ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, StatementTupleExpr expr, List<BindingSet> bindings)
ParallelCheckJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, CheckStatementPattern 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 and 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 and Description
protected ParallelExecutor<BindingSet>	ParallelUnionTask.unionControl
protected ParallelExecutor<BindingSet>	ParallelPreparedUnionTask.unionControl
protected ParallelExecutor<Statement>	ParallelGetStatementsTask.unionControl
protected ParallelExecutor<BindingSet>	ParallelPreparedAlgebraUnionTask.unionControl
protected ParallelExecutor<BindingSet>	ParallelUnionOperatorTask.unionControl

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

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

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

Constructor and 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, FederationEvalStrategy strategy, TupleExpr 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 and Description
protected static class	SourceSelection.SourceSelectionExecutorWithLatch

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

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