You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/10/21 20:40:48 UTC
[1/2] incubator-beam git commit: Use DisplayData delegate in Dataflow
Read transform override
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 <sw...@google.com>
Authored: Fri Oct 21 11:41:41 2016 -0700
Committer: Scott Wegner <sw...@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() {
[2/2] incubator-beam git commit: Closes #1155
Posted by bc...@apache.org.
Closes #1155
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/18e5d128
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/18e5d128
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/18e5d128
Branch: refs/heads/master
Commit: 18e5d128b7918f743c57d8c735452b559bea25e8
Parents: 1533511 4869ef1
Author: bchambers <bc...@google.com>
Authored: Fri Oct 21 13:27:37 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Fri Oct 21 13:27:37 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/runners/dataflow/DataflowRunner.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------