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 classParallelExecutorBase<T>Base class for common parallel executors such asJoinExecutorBaseandUnionExecutorBase.classParallelServiceExecutorParallel executor forFedXServicenodes, 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 voidControlledWorkerScheduler. informFinish(ParallelExecutor<T> control)Inform this scheduler that the specified control instance will no longer submit tasks.booleanControlledWorkerScheduler. isRunning(ParallelExecutor<T> control)Determine if there are still task running or queued for the specified control.voidControlledWorkerScheduler. 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 classControlledWorkerBindJoinExecution of a regular join as bind join.classControlledWorkerBindJoinBaseBase class for executing joins as bind joins (i.e., the bindings of a block are injected in the SPARQL query as VALUES clause).classControlledWorkerBindLeftJoinBind join implementation for left joins (i.e., OPTIOAL clauses)classControlledWorkerBoundJoinDeprecated, for removal: This API element is subject to removal in a future version.replaced withControlledWorkerBindJoinlclassControlledWorkerJoinExecute the nested loop join in an asynchronous fashion, i.e.classControlledWorkerLeftJoinExecute the nested loop join in an asynchronous fashion, i.e.classHashJoinOperator for a hash join of tuple expressions.classJoinExecutorBase<T>Base class for any join parallel join executor.classSynchronousBoundJoinExecute the nested loop join in a synchronous fashion, using grouped requests, i.e.classSynchronousJoinExecute 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. joinControlprotected ParallelExecutor<BindingSet>ParallelBoundJoinTask. joinControlprotected ParallelExecutor<BindingSet>ParallelCheckJoinTask. joinControlDeprecated, for removal: This API element is subject to removal in a future version.protected ParallelExecutor<BindingSet>ParallelJoinTask. joinControlprotected ParallelExecutor<BindingSet>ParallelLeftJoinTask. joinControlprotected ParallelExecutor<BindingSet>ParallelServiceJoinTask. joinControlMethods 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 classControlledWorkerUnion<T>Execution of union tasks withControlledWorkerScheduler.classSynchronousWorkerUnion<T>Synchronous execution of union tasks, i.e.classUnionExecutorBase<T>Base class for any parallel union executor.classWorkerUnionBase<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. unionControlprotected ParallelExecutor<BindingSet>ParallelPreparedAlgebraUnionTask. unionControlprotected ParallelExecutor<BindingSet>ParallelPreparedUnionTask. unionControlprotected ParallelExecutor<BindingSet>ParallelUnionOperatorTask. unionControlprotected ParallelExecutor<BindingSet>ParallelUnionTask. unionControlMethods 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 classSourceSelection.SourceSelectionExecutorWithLatchMethods in org.eclipse.rdf4j.federated.optimizer that return ParallelExecutor Modifier and Type Method Description ParallelExecutor<BindingSet>SourceSelection.ParallelCheckTask. getControl()
-