Class DefaultSchedulerFactory
- java.lang.Object
-
- org.eclipse.rdf4j.federated.evaluation.concurrent.DefaultSchedulerFactory
-
- All Implemented Interfaces:
SchedulerFactory
public class DefaultSchedulerFactory extends Object implements SchedulerFactory
The defaultSchedulerFactory
-
-
Field Summary
Fields Modifier and Type Field Description static DefaultSchedulerFactory
INSTANCE
-
Constructor Summary
Constructors Constructor Description DefaultSchedulerFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ControlledWorkerScheduler<BindingSet>
createJoinScheduler(FederationContext federationContext, int nWorkers)
Create aControlledWorkerScheduler
for regular joins (e.g., the sub-queries generated as part of bind joins)ControlledWorkerScheduler<BindingSet>
createLeftJoinScheduler(FederationContext federationContext, int nWorkers)
Create aControlledWorkerScheduler
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 aControlledWorkerScheduler
for unions (e.g., for executing UNION operands in parallel)
-
-
-
Field Detail
-
INSTANCE
public static final DefaultSchedulerFactory INSTANCE
-
-
Method Detail
-
createJoinScheduler
public ControlledWorkerScheduler<BindingSet> createJoinScheduler(FederationContext federationContext, int nWorkers)
Description copied from interface:SchedulerFactory
Create aControlledWorkerScheduler
for regular joins (e.g., the sub-queries generated as part of bind joins)- Specified by:
createJoinScheduler
in interfaceSchedulerFactory
- Returns:
- See Also:
ControlledWorkerBindJoin
,ParallelBoundJoinTask
-
createUnionScheduler
public ControlledWorkerScheduler<BindingSet> createUnionScheduler(FederationContext federationContext, int nWorkers)
Description copied from interface:SchedulerFactory
Create aControlledWorkerScheduler
for unions (e.g., for executing UNION operands in parallel)- Specified by:
createUnionScheduler
in interfaceSchedulerFactory
- Returns:
-
createLeftJoinScheduler
public ControlledWorkerScheduler<BindingSet> createLeftJoinScheduler(FederationContext federationContext, int nWorkers)
Description copied from interface:SchedulerFactory
Create aControlledWorkerScheduler
for left joins (e.g., the sub-queries generated as part of left bind joins, i.e. OPTIONAL)- Specified by:
createLeftJoinScheduler
in interfaceSchedulerFactory
- Returns:
- See Also:
ControlledWorkerBindLeftJoin
,ParallelBindLeftJoinTask
-
-