From 95318f807c43439a682558b229abf332a2102ab8 Mon Sep 17 00:00:00 2001 From: Thomas Groh Date: Tue, 11 Apr 2017 16:22:45 -0700 Subject: [PATCH] Permit the Transform of an AppliedPTransform to be null This is the case if and only if the AppliedPTransform is the root node. The root node will have an empty full name, an empty input, an empty output, a null transform, and a Pipeline. --- .../java/org/apache/beam/sdk/transforms/AppliedPTransform.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/AppliedPTransform.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/AppliedPTransform.java index 8d99a62c08c9..9009443ce8a4 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/AppliedPTransform.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/AppliedPTransform.java @@ -19,6 +19,7 @@ import com.google.auto.value.AutoValue; import java.util.Map; +import javax.annotation.Nullable; import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.values.PInput; import org.apache.beam.sdk.values.POutput; @@ -62,6 +63,7 @@ AppliedPTransform of( public abstract Map, PValue> getOutputs(); + @Nullable public abstract TransformT getTransform(); public abstract Pipeline getPipeline();