Uses of Interface
org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutor
Packages that use ParallelExecutor
Package
Description
-
Uses of ParallelExecutor in org.eclipse.rdf4j.federated.evaluation.concurrent
Classes in org.eclipse.rdf4j.federated.evaluation.concurrent that implement ParallelExecutorModifier and TypeClassDescriptionclass
Base class for common parallel executors such asJoinExecutorBase
andUnionExecutorBase
.class
Parallel executor forFedXService
nodes, which wrap SERVICE expressions.Methods in org.eclipse.rdf4j.federated.evaluation.concurrent that return ParallelExecutorModifier and TypeMethodDescriptionParallelTask.getControl()
return the controlling instance, e.g.Methods in org.eclipse.rdf4j.federated.evaluation.concurrent with parameters of type ParallelExecutorModifier and TypeMethodDescriptionvoid
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 ParallelExecutorModifier and TypeClassDescriptionclass
Execution of a regular join as bind join.class
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
Bind join implementation for left joins (i.e., OPTIOAL clauses)class
Deprecated, for removal: This API element is subject to removal in a future version.class
Execute the nested loop join in an asynchronous fashion, i.e.class
Execute the nested loop join in an asynchronous fashion, i.e.class
Operator for a hash join of tuple expressions.class
Base class for any join parallel join executor.class
Execute the nested loop join in a synchronous fashion, using grouped requests, i.e.class
Execute the nested loop join in a synchronous fashion, i.e.Fields in org.eclipse.rdf4j.federated.evaluation.join declared as ParallelExecutorModifier and TypeFieldDescriptionprotected 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 ParallelExecutorModifier and TypeMethodDescriptionParallelBindLeftJoinTask.getControl()
ParallelBoundJoinTask.getControl()
ParallelCheckJoinTask.getControl()
Deprecated, for removal: This API element is subject to removal in a future version.ParallelEmptyBindLeftJoinTask.getControl()
ParallelJoinTask.getControl()
ParallelLeftJoinTask.getControl()
ParallelServiceJoinTask.getControl()
Methods in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ParallelExecutorModifier and TypeMethodDescriptionControlledWorkerBindJoin.BoundJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBindJoin.CheckJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) Deprecated, for removal: This API element is subject to removal in a future version.ControlledWorkerBindJoin.FedXServiceJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBindJoinBase.TaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBindLeftJoin.EmptyLeftBoundJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBindLeftJoin.LeftBoundJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBoundJoin.BoundJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBoundJoin.CheckJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBoundJoin.FedXServiceJoinTaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) ControlledWorkerBoundJoin.TaskCreator.getTask
(ParallelExecutor<BindingSet> control, List<BindingSet> bindings) Constructors in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ParallelExecutorModifierConstructorDescriptionParallelBindLeftJoinTask
(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 ParallelExecutorModifier and TypeClassDescriptionclass
Execution of union tasks withControlledWorkerScheduler
.class
Synchronous execution of union tasks, i.e.class
Base class for any parallel union executor.class
Base class for worker unions providing convenience functions to add tasks.Fields in org.eclipse.rdf4j.federated.evaluation.union declared as ParallelExecutorModifier and TypeFieldDescriptionprotected 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 ParallelExecutorModifier and TypeMethodDescriptionParallelGetStatementsTask.getControl()
ParallelPreparedAlgebraUnionTask.getControl()
ParallelPreparedUnionTask.getControl()
ParallelUnionOperatorTask.getControl()
ParallelUnionTask.getControl()
Constructors in org.eclipse.rdf4j.federated.evaluation.union with parameters of type ParallelExecutorModifierConstructorDescriptionParallelGetStatementsTask
(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 ParallelExecutorModifier and TypeClassDescriptionprotected static class
Methods in org.eclipse.rdf4j.federated.optimizer that return ParallelExecutor
ControlledWorkerBindJoin
l