You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/04/13 16:16:15 UTC
[2/2] beam git commit: Represent a Pipeline via a list of Top-level
Transforms
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 <tg...@google.com>
Authored: Tue Apr 11 16:42:28 2017 -0700
Committer: Thomas Groh <tg...@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.