Repository: incubator-beam Updated Branches: refs/heads/master 153351126 -> 18e5d128b
Use DisplayData delegate in Dataflow Read transform override Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4869ef19 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4869ef19 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4869ef19 Branch: refs/heads/master Commit: 4869ef19fa70769831dacc2ac332ec0a11b3f9d8 Parents: 1533511 Author: Scott Wegner <sweg...@google.com> Authored: Fri Oct 21 11:41:41 2016 -0700 Committer: Scott Wegner <sweg...@google.com> Committed: Fri Oct 21 12:32:42 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/dataflow/DataflowRunner.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4869ef19/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java index 7bf270d..89c364e 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java @@ -2248,10 +2248,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> { @Override public void populateDisplayData(DisplayData.Builder builder) { - super.populateDisplayData(builder); - builder - .add(DisplayData.item("source", source.getClass())) - .include("source", source); + builder.delegate(source); } public UnboundedSource<T, ?> getSource() {
