Package org.eclipse.rdf4j.federated.evaluation.concurrent

Interface SchedulerFactory

All Known Implementing Classes:

DefaultSchedulerFactory

public interface SchedulerFactory

Factory for creating ControlledWorkerScheduler for executing subqueries (e.g. joins) in the background

Author:

Andreas Schwarte

See Also:

• DefaultSchedulerFactory

Method Summary

Modifier and Type	Method	Description
ControlledWorkerScheduler<BindingSet>	createJoinScheduler(FederationContext federationContext, int nWorkers)	Create a ControlledWorkerScheduler for regular joins (e.g., the sub-queries generated as part of bind joins)
ControlledWorkerScheduler<BindingSet>	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>	createUnionScheduler(FederationContext federationContext, int nWorkers)	Create a ControlledWorkerScheduler for unions (e.g., for executing UNION operands in parallel)

Method Details

createJoinScheduler

ControlledWorkerScheduler<BindingSet> createJoinScheduler(FederationContext federationContext,
 int nWorkers)

Create a ControlledWorkerScheduler for regular joins (e.g., the sub-queries generated as part of bind joins)

Parameters:

federationContext -

nWorkers -

Returns:

See Also:

• ControlledWorkerBindJoin
• ParallelBoundJoinTask

createUnionScheduler

ControlledWorkerScheduler<BindingSet> createUnionScheduler(FederationContext federationContext,
 int nWorkers)

Create a ControlledWorkerScheduler for unions (e.g., for executing UNION operands in parallel)

Parameters:

federationContext -

nWorkers -

Returns:

createLeftJoinScheduler

ControlledWorkerScheduler<BindingSet> 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. OPTIONAL)

Parameters:

federationContext -

nWorkers -

Returns:

See Also:

• ControlledWorkerBindLeftJoin
• ParallelBindLeftJoinTask