Package nz.org.riskscape.engine.pipeline

Class DefaultPipelineExecutor

java.lang.Object
nz.org.riskscape.engine.pipeline.DefaultPipelineExecutor
All Implemented Interfaces:
nz.org.riskscape.engine.pipeline.PipelineExecutor
Direct Known Subclasses:
SchedulerBasedExecutor
public abstract class DefaultPipelineExecutor extends Object implements nz.org.riskscape.engine.pipeline.PipelineExecutor

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static enum 
    DefaultPipelineExecutor.ProblemCodes
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final nz.org.riskscape.engine.Engine
    engine
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultPipelineExecutor(nz.org.riskscape.engine.Engine engine)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    nz.org.riskscape.problem.ResultOrProblems<Map<String,List<?>>>
    filterParams(nz.org.riskscape.engine.bind.BindingContext context, nz.org.riskscape.engine.pipeline.NamedStep step, Map<String,List<?>> unboundParameters)
     
    int
    getNumThreads()
     
    boolean
    isParallelizationEnabled()
     
    nz.org.riskscape.engine.pipeline.ExecutionContext
    newExecutionContext(nz.org.riskscape.engine.Project project)
     
    nz.org.riskscape.engine.pipeline.RealizedPipeline
    realize(@NonNull nz.org.riskscape.engine.pipeline.ExecutionContext context, @NonNull nz.org.riskscape.engine.pipeline.Pipeline pipeline)
     
    void
    setNumThreads(int numThreads)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface nz.org.riskscape.engine.pipeline.PipelineExecutor

    execute

  • Field Details

    • engine

      protected final nz.org.riskscape.engine.Engine engine

  • Constructor Details

    • DefaultPipelineExecutor

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

  • Method Details

    • filterParams

      public nz.org.riskscape.problem.ResultOrProblems<Map<String,List<?>>> filterParams(nz.org.riskscape.engine.bind.BindingContext context, nz.org.riskscape.engine.pipeline.NamedStep step, Map<String,List<?>> unboundParameters)

    • realize

      public nz.org.riskscape.engine.pipeline.RealizedPipeline realize(@NonNull @NonNull nz.org.riskscape.engine.pipeline.ExecutionContext context, @NonNull @NonNull nz.org.riskscape.engine.pipeline.Pipeline pipeline)
      Specified by:
      realize in interface nz.org.riskscape.engine.pipeline.PipelineExecutor

    • newExecutionContext

      public nz.org.riskscape.engine.pipeline.ExecutionContext newExecutionContext(nz.org.riskscape.engine.Project project)
      Specified by:
      newExecutionContext in interface nz.org.riskscape.engine.pipeline.PipelineExecutor

    • isParallelizationEnabled

      public boolean isParallelizationEnabled()

    • getNumThreads

      public int getNumThreads()
      Specified by:
      getNumThreads in interface nz.org.riskscape.engine.pipeline.PipelineExecutor

    • setNumThreads

      public void setNumThreads(int numThreads)
      Specified by:
      setNumThreads in interface nz.org.riskscape.engine.pipeline.PipelineExecutor