public class ProtoOverrides
extends java.lang.Object
PTransformOverride
.
This should generally be used by runners to replace transforms within graphs. SDK construction
code should rely on the more powerful and native Pipeline.replaceAll(List)
.
Modifier and Type | Class and Description |
---|---|
static interface |
ProtoOverrides.TransformReplacement
A Function that takes a transform and the existing components and returns the new composite
PTransform and additional components.
|
Constructor and Description |
---|
ProtoOverrides() |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline |
updateTransform(java.lang.String urn,
org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline originalPipeline,
ProtoOverrides.TransformReplacement compositeBuilder)
Update all composites present in the
originalPipeline with an URN equal to the provided
urn using the provided ProtoOverrides.TransformReplacement . |
public static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline updateTransform(java.lang.String urn, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline originalPipeline, ProtoOverrides.TransformReplacement compositeBuilder)
originalPipeline
with an URN equal to the provided
urn
using the provided ProtoOverrides.TransformReplacement
.