Repository: beam Updated Branches: refs/heads/master 9e4b140ed -> aaf0884d5
This closes #2039 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aaf0884d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aaf0884d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aaf0884d Branch: refs/heads/master Commit: aaf0884d50eae620fc76e906ef4591c514ccb4d7 Parents: 9e4b140 a6cd8c3 Author: Thomas Groh <[email protected]> Authored: Mon Feb 27 09:06:13 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Mon Feb 27 09:06:13 2017 -0800 ---------------------------------------------------------------------- .../EmptyFlattenAsCreateFactory.java | 72 ++++ .../UnsupportedOverrideFactory.java | 6 +- runners/google-cloud-dataflow-java/pom.xml | 11 +- .../dataflow/DataflowPipelineTranslator.java | 46 +-- .../beam/runners/dataflow/DataflowRunner.java | 414 ++++++++++++------- .../dataflow/StreamingViewOverrides.java | 1 - .../DataflowPipelineTranslatorTest.java | 22 +- .../runners/dataflow/DataflowRunnerTest.java | 8 +- .../org/apache/beam/sdk/util/NameUtils.java | 7 +- 9 files changed, 396 insertions(+), 191 deletions(-) ----------------------------------------------------------------------
