Repository: beam Updated Branches: refs/heads/master 2723d38a6 -> e5f1a6479
This closes #2325 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e5f1a647 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e5f1a647 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e5f1a647 Branch: refs/heads/master Commit: e5f1a6479c0a7c6f531c340fe371e4b66e7ea2a5 Parents: 2723d38 6bfde5d Author: Thomas Groh <tg...@google.com> Authored: Fri Mar 24 17:46:53 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri Mar 24 17:46:53 2017 -0700 ---------------------------------------------------------------------- .../DeduplicatedFlattenFactory.java | 109 ++++++++++++++++++ .../EmptyFlattenAsCreateFactory.java | 15 ++- .../core/construction/PTransformMatchers.java | 26 +++++ .../DeduplicatedFlattenFactoryTest.java | 112 +++++++++++++++++++ .../EmptyFlattenAsCreateFactoryTest.java | 96 ++++++++++++++++ .../construction/PTransformMatchersTest.java | 67 +++++++++++ runners/google-cloud-dataflow-java/pom.xml | 3 - .../beam/runners/dataflow/DataflowRunner.java | 5 +- 8 files changed, 427 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
