beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [2/2] beam git commit: Represent a Pipeline via a list of Top-level Transforms
Date Thu, 13 Apr 2017 16:16:15 GMT
Represent a Pipeline via a list of Top-level Transforms

The root node is a synthetic transform which does not appear within the
graph, as it never has any components of note. Instead of referring to a
single "root node" in the Pipeline message, refer to the top-level nodes
which do not have an enclosing PTransform.


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5a517f89
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5a517f89
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5a517f89

Branch: refs/heads/master
Commit: 5a517f89ac3205c23b65a33315233f3f331d0367
Parents: 4c4fdf2
Author: Thomas Groh <tgroh@google.com>
Authored: Tue Apr 11 16:42:28 2017 -0700
Committer: Thomas Groh <tgroh@google.com>
Committed: Thu Apr 13 09:16:04 2017 -0700

----------------------------------------------------------------------
 sdks/common/runner-api/src/main/proto/beam_runner_api.proto | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/5a517f89/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
----------------------------------------------------------------------
diff --git a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
index ebbd928..bf4df2a 100644
--- a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
+++ b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
@@ -92,8 +92,8 @@ message Pipeline {
   // this pipeline.
   Components components = 1;
 
-  // (Required) The id of the PTransform that is the root of the pipeline
-  string root_transform_id = 2;
+  // (Required) The ids of all PTransforms that are not contained within another PTransform
+  repeated string root_transform_ids = 2;
 
   // (Optional) Static display data for the pipeline. If there is none,
   // it may be omitted.


Mime
View raw message