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.

  • 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)