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 2018/04/16 18:36:56 UTC
[beam] 01/01: Merge pull request #5118: Identify side inputs by
transform id and local name
This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit a7819fec7cfb74e96979dcb5055567dcba827cfa
Merge: 5f75e14 a1f3f2b
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Mon Apr 16 11:36:52 2018 -0700
Merge pull request #5118: Identify side inputs by transform id and local name
[BEAM-4056]
.../pipeline/src/main/proto/beam_runner_api.proto | 18 +++++--
.../core/construction/graph/ExecutableStage.java | 22 +++++---
.../core/construction/graph/GreedyStageFuser.java | 2 +-
.../graph/ImmutableExecutableStage.java | 6 +--
.../core/construction/graph/QueryablePipeline.java | 17 +++---
.../construction/graph/SideInputReference.java | 61 ++++++++++++++++++++++
.../construction/graph/ExecutableStageMatcher.java | 36 +++++++++++--
.../construction/graph/ExecutableStageTest.java | 7 ++-
.../graph/GreedyPipelineFuserTest.java | 6 +++
.../construction/graph/GreedyStageFuserTest.java | 10 ++--
.../graph/ImmutableExecutableStageTest.java | 7 ++-
.../construction/graph/QueryablePipelineTest.java | 24 ++++++---
12 files changed, 177 insertions(+), 39 deletions(-)
--
To stop receiving notification emails like this one, please contact
tgroh@apache.org.