Class RealizedPipeline

Method Details

• close

  public void close()

  Specified by:

  close in interface AutoCloseable

• getStartSteps

  public Set<RealizedStep> getStartSteps()

• getEndSteps

  public Set<RealizedStep> getEndSteps()

• getFailures

  public List<Problem> getFailures()

• hasFailures

  public boolean hasFailures()

• getPipeline

  public Pipeline getPipeline()

  Returns:

  the Pipeline this RealizedPipeline originates from.

• getStep

  public Optional<RealizedStep> getStep(String stepName)

  Returns:

  a step by its name within the pipeline (c.f. NamedStep), or empty if none can be found

• clone

  public RealizedPipeline clone()

  Overrides:

  clone in class Object

  Returns:

  a copy of this realized pipeline, copying references to any immutable members, and cloning anything that's mutable

• drainWarnings

  public RealizedPipeline drainWarnings(Consumer<Problem> problemConsumer)

  Returns:

  the RealizedPipeline with any warnings removed and passed to the problemConsumer

• getOriginal

  public Pipeline getOriginal()

• getRealizedSteps

  public List<RealizedStep> getRealizedSteps()

• equals

  public boolean equals(Object o)

  Overrides:

  equals in class Object

• canEqual

  protected boolean canEqual(Object other)

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object

• toString

  public String toString()

  Overrides:

  toString in class Object

• getContext

  public ExecutionContext getContext()