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 classControlledWorkerBoundJoinExecute the nested loop join in an asynchronous fashion, using grouped requests, i.e.classControlledWorkerJoinExecute 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>ParallelBoundJoinTask. joinControlprotected ParallelExecutor<BindingSet>ParallelCheckJoinTask. joinControlprotected 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>ParallelBoundJoinTask. getControl()ParallelExecutor<BindingSet>ParallelCheckJoinTask. 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>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 Constructor 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 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()
-