Uses of Class
org.eclipse.rdf4j.federated.evaluation.concurrent.ControlledWorkerScheduler
Packages that use ControlledWorkerScheduler
Package
Description
-
Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated
Methods in org.eclipse.rdf4j.federated that return ControlledWorkerSchedulerModifier and TypeMethodDescriptionFederationManager.getJoinScheduler()FederationManager.getLeftJoinScheduler()FederationManager.getUnionScheduler() -
Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated.evaluation
Methods in org.eclipse.rdf4j.federated.evaluation with parameters of type ControlledWorkerSchedulerModifier and TypeMethodDescriptionprotected abstract CloseableIteration<BindingSet>FederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVariables, BindingSet bindings, QueryInfo queryInfo) Execute the join in a separate thread using some join executor.SailFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) SparqlFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) protected abstract CloseableIteration<BindingSet>FederationEvalStrategy.executeLeftJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) Execute the left join in a separate thread using some join executor.protected CloseableIteration<BindingSet>SailFederationEvalStrategy.executeLeftJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) protected CloseableIteration<BindingSet>SparqlFederationEvalStrategy.executeLeftJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo) -
Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated.evaluation.concurrent
Methods in org.eclipse.rdf4j.federated.evaluation.concurrent that return ControlledWorkerSchedulerModifier and TypeMethodDescriptionDefaultSchedulerFactory.createJoinScheduler(FederationContext federationContext, int nWorkers) SchedulerFactory.createJoinScheduler(FederationContext federationContext, int nWorkers) Create aControlledWorkerSchedulerfor regular joins (e.g., the sub-queries generated as part of bind joins)DefaultSchedulerFactory.createLeftJoinScheduler(FederationContext federationContext, int nWorkers) SchedulerFactory.createLeftJoinScheduler(FederationContext federationContext, int nWorkers) Create aControlledWorkerSchedulerfor left joins (e.g., the sub-queries generated as part of left bind joins, i.e.DefaultSchedulerFactory.createUnionScheduler(FederationContext federationContext, int nWorkers) SchedulerFactory.createUnionScheduler(FederationContext federationContext, int nWorkers) Create aControlledWorkerSchedulerfor unions (e.g., for executing UNION operands in parallel) -
Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated.evaluation.join
Fields in org.eclipse.rdf4j.federated.evaluation.join declared as ControlledWorkerSchedulerModifier and TypeFieldDescriptionprotected final ControlledWorkerScheduler<BindingSet>ControlledWorkerBindJoinBase.schedulerprotected final ControlledWorkerScheduler<BindingSet>ControlledWorkerJoin.schedulerprotected final ControlledWorkerScheduler<BindingSet>ControlledWorkerLeftJoin.schedulerConstructors in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ControlledWorkerSchedulerModifierConstructorDescriptionControlledWorkerBindJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBindJoinBase(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBindLeftJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerBoundJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) Deprecated, for removal: This API element is subject to removal in a future version.ControlledWorkerJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) ControlledWorkerLeftJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet> leftIter, LeftJoin join, BindingSet bindings, QueryInfo queryInfo) -
Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated.evaluation.union
Fields in org.eclipse.rdf4j.federated.evaluation.union declared as ControlledWorkerSchedulerModifier and TypeFieldDescriptionprotected final ControlledWorkerScheduler<T>ControlledWorkerUnion.schedulerConstructors in org.eclipse.rdf4j.federated.evaluation.union with parameters of type ControlledWorkerSchedulerModifierConstructorDescriptionControlledWorkerUnion(ControlledWorkerScheduler<T> scheduler, QueryInfo queryInfo)