org.apache.beam.sdk.util.construction.graph

Class GreedyPipelineFuser

java.lang.Object

org.apache.beam.sdk.util.construction.graph.GreedyPipelineFuser

public class GreedyPipelineFuser
extends java.lang.Object

Fuses a RunnerApi.Pipeline into some set of single-environment executable transforms.

Method Summary

Modifier and Type	Method and Description
static FusedPipeline	fuse(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p) Fuses a RunnerApi.Pipeline into a collection of ExecutableStages.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fuse

public static FusedPipeline fuse(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p)

Fuses a RunnerApi.Pipeline into a collection of ExecutableStages.

This fuser expects each ExecutableStage to have exactly one input. This means that pipelines must be rooted at Impulse, or other runner-executed primitive transforms.