This closes #2618: Use step-derived PCollection names in Dataflow Derive Dataflow output names from steps, not PCollection names Make crashing errors in Structs unchecked exceptions
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e4eae7bc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e4eae7bc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e4eae7bc Branch: refs/heads/master Commit: e4eae7bce4da75744379711d8f45d00b2ba07ad3 Parents: 524165a c9ed8f9 Author: Kenneth Knowles <k...@google.com> Authored: Thu Apr 20 18:19:18 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Apr 20 18:19:18 2017 -0700 ---------------------------------------------------------------------- .../dataflow/DataflowPipelineTranslator.java | 7 +- .../DataflowPipelineTranslatorTest.java | 94 ++++++++++++++++++++ .../java/org/apache/beam/sdk/util/Structs.java | 74 +++++++-------- 3 files changed, 131 insertions(+), 44 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/e4eae7bc/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslatorTest.java ----------------------------------------------------------------------