Uses of Interface
org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutor
-
-
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 asJoinExecutorBase
andUnionExecutorBase
.class
ParallelServiceExecutor
Parallel executor forFedXService
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 withControlledWorkerBindJoin
lclass
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 ParallelExecutor<BindingSet>
ParallelBindLeftJoinTask. joinControl
protected ParallelExecutor<BindingSet>
ParallelBoundJoinTask. joinControl
protected ParallelExecutor<BindingSet>
ParallelCheckJoinTask. joinControl
Deprecated, for removal: This API element is subject to removal in a future version.protected ParallelExecutor<BindingSet>
ParallelJoinTask. joinControl
protected ParallelExecutor<BindingSet>
ParallelLeftJoinTask. joinControl
protected 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>
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.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)
-
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 withControlledWorkerScheduler
.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 ParallelExecutor<Statement>
ParallelGetStatementsTask. unionControl
protected ParallelExecutor<BindingSet>
ParallelPreparedAlgebraUnionTask. unionControl
protected ParallelExecutor<BindingSet>
ParallelPreparedUnionTask. unionControl
protected ParallelExecutor<BindingSet>
ParallelUnionOperatorTask. unionControl
protected 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 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()
-