This closes #2040
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/932bb823 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/932bb823 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/932bb823 Branch: refs/heads/master Commit: 932bb823fca2547186b3b5208547861ec710ec76 Parents: 063fbd4 24613fd Author: Thomas Groh <tg...@google.com> Authored: Mon Feb 27 11:09:22 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Mon Feb 27 11:09:22 2017 -0800 ---------------------------------------------------------------------- .../core/construction/PTransformMatchers.java | 32 ++--- .../construction/PTransformMatchersTest.java | 43 ++++++ .../beam/runners/direct/DirectRunner.java | 3 +- .../direct/WriteWithShardingFactory.java | 144 ++++++++----------- .../direct/WriteWithShardingFactoryTest.java | 141 +++++------------- 5 files changed, 155 insertions(+), 208 deletions(-) ----------------------------------------------------------------------
