Uses of Class
org.eclipse.rdf4j.federated.evaluation.concurrent.ControlledWorkerScheduler

Packages that use ControlledWorkerScheduler

Package	Description
org.eclipse.rdf4j.federated
org.eclipse.rdf4j.federated.evaluation
org.eclipse.rdf4j.federated.evaluation.concurrent
org.eclipse.rdf4j.federated.evaluation.join
org.eclipse.rdf4j.federated.evaluation.union

Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated

Methods in org.eclipse.rdf4j.federated that return ControlledWorkerScheduler

Modifier and Type	Method	Description
ControlledWorkerScheduler<BindingSet>	FederationManager.getJoinScheduler()
ControlledWorkerScheduler<BindingSet>	FederationManager.getLeftJoinScheduler()
ControlledWorkerScheduler<BindingSet>	FederationManager.getUnionScheduler()

Uses of ControlledWorkerScheduler in org.eclipse.rdf4j.federated.evaluation

Methods in org.eclipse.rdf4j.federated.evaluation with parameters of type ControlledWorkerScheduler

Modifier and Type	Method	Description
protected 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.
CloseableIteration<BindingSet>	SailFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo)
CloseableIteration<BindingSet>	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 ControlledWorkerScheduler

Modifier and Type	Method	Description
ControlledWorkerScheduler<BindingSet>	DefaultSchedulerFactory.createJoinScheduler(FederationContext federationContext, int nWorkers)
ControlledWorkerScheduler<BindingSet>	SchedulerFactory.createJoinScheduler(FederationContext federationContext, int nWorkers)	Create a ControlledWorkerScheduler for regular joins (e.g., the sub-queries generated as part of bind joins)
ControlledWorkerScheduler<BindingSet>	DefaultSchedulerFactory.createLeftJoinScheduler(FederationContext federationContext, int nWorkers)
ControlledWorkerScheduler<BindingSet>	SchedulerFactory.createLeftJoinScheduler(FederationContext federationContext, int nWorkers)	Create a ControlledWorkerScheduler for left joins (e.g., the sub-queries generated as part of left bind joins, i.e.
ControlledWorkerScheduler<BindingSet>	DefaultSchedulerFactory.createUnionScheduler(FederationContext federationContext, int nWorkers)
ControlledWorkerScheduler<BindingSet>	SchedulerFactory.createUnionScheduler(FederationContext federationContext, int nWorkers)	Create a ControlledWorkerScheduler for 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 ControlledWorkerScheduler

Modifier and Type	Field	Description
protected final ControlledWorkerScheduler<BindingSet>	ControlledWorkerBindJoinBase.scheduler
protected final ControlledWorkerScheduler<BindingSet>	ControlledWorkerJoin.scheduler
protected final ControlledWorkerScheduler<BindingSet>	ControlledWorkerLeftJoin.scheduler

Constructors in org.eclipse.rdf4j.federated.evaluation.join with parameters of type ControlledWorkerScheduler

Modifier	Constructor	Description
	ControlledWorkerBindJoin(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 ControlledWorkerScheduler

Modifier and Type	Field	Description
protected final ControlledWorkerScheduler<T>	ControlledWorkerUnion.scheduler

Constructors in org.eclipse.rdf4j.federated.evaluation.union with parameters of type ControlledWorkerScheduler

Modifier	Constructor	Description
	ControlledWorkerUnion(ControlledWorkerScheduler<T> scheduler, QueryInfo queryInfo)