Interface PipelineManager<M>

All Known Implementing Classes:
AbstractPipelineManager

public interface PipelineManager<M>
  • Method Details

    • getPipeline

      Optional<Pipeline<M>> getPipeline(String pipelineId)
      Return the current pipeline instance for the given id, if it exists
      Parameters:
      pipelineId -
    • getOrCreatePipeline

      Pipeline<M> getOrCreatePipeline(String pipelineId)
      Return the current pipeline instance for the given id, or create one
      Parameters:
      pipelineId -
      Returns:
    • getOrCreatePipeline

      @Deprecated Pipeline<M> getOrCreatePipeline(String pipelineId, Map<String,String> initialProperties)
      Deprecated.
      Return the current pipeline instance for the given id, or create one
      Parameters:
      pipelineId -
      initialProperties - - not used
      Returns:
    • finalizeJob

      void finalizeJob(String pipelineId)