Move the step output ids to use a flat namespace. This closes #1099
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d69b324c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d69b324c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d69b324c Branch: refs/heads/master Commit: d69b324c482b7960194781e86666b2cfa9d4702a Parents: b8e6eea 1778200 Author: Luke Cwik <[email protected]> Authored: Mon Oct 17 11:48:18 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Mon Oct 17 11:48:18 2016 -0700 ---------------------------------------------------------------------- .../dataflow/DataflowPipelineTranslator.java | 111 ++++++++++++------- .../beam/runners/dataflow/DataflowRunner.java | 12 +- .../dataflow/internal/ReadTranslator.java | 2 +- .../beam/runners/dataflow/util/DoFnInfo.java | 30 +++-- .../DataflowPipelineTranslatorTest.java | 38 ++++++- .../runners/dataflow/DataflowRunnerTest.java | 6 +- 6 files changed, 136 insertions(+), 63 deletions(-) ----------------------------------------------------------------------
