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, PipelineDeclaration pipeline, List<RealizedStep> steps)
RealizedPipeline(ExecutionContext context, PipelineDeclaration ast, List<RealizedStep> realizedSteps, List<Problem> problems)

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()	The source code that was realized to produce this realized pipeline
ExecutionContext	getContext()
Set<RealizedStep>	getDependents(RealizedStep step)
Set<RealizedStep>	getEndSteps()
List<Problem>	getFailures()
PipelineMetadata	getMetadata()
List<RealizedStep>	getRealizedSteps()	The individually realized steps, in the order they were realized
Set<RealizedStep>	getStartSteps()
Optional<RealizedStep>	getStep(String stepName)
boolean	hasFailures()
int	hashCode()
RealizedPipeline	withMetadata(PipelineMetadata newMetadata)

Methods inherited from class java.lang.Object

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

Constructor Details

RealizedPipeline

public RealizedPipeline(ExecutionContext context,
 PipelineDeclaration pipeline,
 List<RealizedStep> steps)

RealizedPipeline

public RealizedPipeline(ExecutionContext context,
 PipelineDeclaration ast,
 List<RealizedStep> realizedSteps,
 List<Problem> problems)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

getStartSteps

public Set<RealizedStep> getStartSteps()

Returns:

the set of steps that have no dependencies

getEndSteps

public Set<RealizedStep> getEndSteps()

Returns:

the set of RealizedSteps that no other steps depend on

getDependents

public Set<RealizedStep> getDependents(RealizedStep step)

Returns:

a Set of RealizedSteps that have a dependency on the given step

getFailures

public List<Problem> getFailures()

hasFailures

public boolean hasFailures()

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

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.

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

getContext

public ExecutionContext getContext()

getAst

public PipelineDeclaration getAst()

The source code that was realized to produce this realized pipeline

getRealizedSteps

public List<RealizedStep> getRealizedSteps()

The individually realized steps, in the order they were realized