public class TrivialNativeTransformExpander
extends java.lang.Object
Constructor and Description |
---|
TrivialNativeTransformExpander() |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline |
forKnownUrns(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
java.util.Set<java.lang.String> knownUrns)
Replaces transforms with the known URN with a native equivalent stripping the environment and
removing any sub-transforms from the returned pipeline.
|
public static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline forKnownUrns(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, java.util.Set<java.lang.String> knownUrns)
pipeline
- the pipeline to be trimmedknownUrns
- set of URNs for the runner's native transforms