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

Class DefaultSchedulerFactory

java.lang.Object

org.eclipse.rdf4j.federated.evaluation.concurrent.DefaultSchedulerFactory

All Implemented Interfaces:

SchedulerFactory

public class DefaultSchedulerFactory
extends Object
implements SchedulerFactory

The default SchedulerFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final DefaultSchedulerFactory	INSTANCE

Constructor Summary

Constructors

Constructor	Description
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final DefaultSchedulerFactory INSTANCE

Constructor Details

DefaultSchedulerFactory

public DefaultSchedulerFactory()

Method Details

createJoinScheduler

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

Description copied from interface: SchedulerFactory

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

Specified by:

createJoinScheduler in interface SchedulerFactory

Parameters:

federationContext -

nWorkers -

Returns:

See Also:

• ControlledWorkerBindJoin
• ParallelBoundJoinTask

createUnionScheduler

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

Description copied from interface: SchedulerFactory

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

Specified by:

createUnionScheduler in interface SchedulerFactory

Parameters:

federationContext -

nWorkers -

Returns:

createLeftJoinScheduler

public ControlledWorkerScheduler<BindingSet> createLeftJoinScheduler(FederationContext federationContext,
 int nWorkers)

Description copied from interface: SchedulerFactory

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

Specified by:

createLeftJoinScheduler in interface SchedulerFactory

Parameters:

federationContext -

nWorkers -

Returns:

See Also:

• ControlledWorkerBindLeftJoin
• ParallelBindLeftJoinTask