Package nz.org.riskscape.engine.pipeline

Class RealizedPipeline

java.lang.Object

nz.org.riskscape.engine.pipeline.RealizedPipeline

All Implemented Interfaces:

AutoCloseable

public class RealizedPipeline
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
RealizedPipeline(ExecutionContext context, Pipeline original, List<RealizedStep> realizedSteps)

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
RealizedPipeline	clone()
void	close()
RealizedPipeline	drainWarnings(Consumer<Problem> problemConsumer)
boolean	equals(Object o)
PipelineDeclaration	getAst()
ExecutionContext	getContext()
Set<RealizedStep>	getEndSteps()
List<Problem>	getFailures()
PipelineMetadata	getMetadata()
Pipeline	getOriginal()
Pipeline	getPipeline()
List<RealizedStep>	getRealizedSteps()
Set<RealizedStep>	getStartSteps()
Optional<RealizedStep>	getStep(String stepName)
boolean	hasFailures()
int	hashCode()
String	toString()
RealizedPipeline	withMetadata(PipelineMetadata newMetadata)

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

RealizedPipeline

public RealizedPipeline(ExecutionContext context,
 Pipeline original,
 List<RealizedStep> realizedSteps)

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

getAst

public PipelineDeclaration getAst()

Returns:

the AST this pipeline was realized from

getMetadata

public PipelineMetadata getMetadata()

Returns:

metadata associated with this RealizedPipeline

withMetadata

public RealizedPipeline withMetadata(PipelineMetadata newMetadata)

Returns:

a copy of this pipeline, with different metadata to the original.

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