public abstract class FusedPipeline
extends java.lang.Object
RunnerApi.Pipeline
which has been separated into collections of executable components.Constructor and Description |
---|
FusedPipeline() |
Modifier and Type | Method and Description |
---|---|
abstract java.util.Set<ExecutableStage> |
getFusedStages()
The
executable stages that are executed by SDK harnesses. |
abstract java.util.Set<java.lang.String> |
getRequirements()
The
PTransforms that a runner is responsible for executing. |
abstract java.util.Set<PipelineNode.PTransformNode> |
getRunnerExecutedTransforms()
The
PTransforms that a runner is responsible for executing. |
org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline |
toPipeline()
Returns the
RunnerApi.Pipeline representation of this FusedPipeline . |
public abstract java.util.Set<ExecutableStage> getFusedStages()
executable stages
that are executed by SDK harnesses.public abstract java.util.Set<PipelineNode.PTransformNode> getRunnerExecutedTransforms()
PTransforms
that a runner is responsible for executing.public abstract java.util.Set<java.lang.String> getRequirements()
PTransforms
that a runner is responsible for executing.public org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline toPipeline()
RunnerApi.Pipeline
representation of this FusedPipeline
.
The RunnerApi.Components
of the returned pipeline will contain all of the PTransforms
present in the original Pipeline that this FusedPipeline
was created from,
plus all of the ExecutableStages
contained within this FusedPipeline
. The RunnerApi.Pipeline.getRootTransformIdsList()
will contain all of the runner
executed transforms and all of the execuable stages
contained within
the Pipeline.