Package nz.org.riskscape.engine.sched

Class SchedulerBasedExecutor

java.lang.Object

nz.org.riskscape.engine.pipeline.DefaultPipelineExecutor

nz.org.riskscape.engine.sched.SchedulerBasedExecutor

All Implemented Interfaces:

nz.org.riskscape.engine.pipeline.PipelineExecutor

public class SchedulerBasedExecutor
extends DefaultPipelineExecutor

Executes a pipeline by breaking the steps down into tasks, and then using a Scheduler to manage running the tasks in parallel where possible. First we take the pipeline and group together steps that can be run together (LinkedSteps). When then take the LinkedSteps and convert them to tasks (TaskSpec) that the Scheduler can run.

Field Summary

Fields inherited from class nz.org.riskscape.engine.pipeline.DefaultPipelineExecutor

engine

Constructor Summary

Constructors

Constructor	Description
SchedulerBasedExecutor(nz.org.riskscape.engine.Engine engine)

Method Summary

Modifier and Type	Method	Description
Future<nz.org.riskscape.engine.pipeline.ExecutionResult>	execute(nz.org.riskscape.engine.output.PipelineJobContext jobContext)

Methods inherited from class nz.org.riskscape.engine.pipeline.DefaultPipelineExecutor

getNumThreads, isParallelizationEnabled, newExecutionContext, setNumThreads

Methods inherited from class java.lang.Object

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

Constructor Details

SchedulerBasedExecutor

public SchedulerBasedExecutor(nz.org.riskscape.engine.Engine engine)

Method Details

execute

public Future<nz.org.riskscape.engine.pipeline.ExecutionResult> execute(nz.org.riskscape.engine.output.PipelineJobContext jobContext)