This closes #1953
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/64102943 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/64102943 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/64102943 Branch: refs/heads/master Commit: 64102943f9c78bdc8a5c14a9247e906b8e185fe1 Parents: cf9d221 078a2ff Author: Thomas Groh <[email protected]> Authored: Wed Feb 8 16:18:31 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Wed Feb 8 16:18:31 2017 -0800 ---------------------------------------------------------------------- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 10 ++++ .../direct/DirectGroupByKeyOverrideFactory.java | 10 ++++ .../direct/ParDoMultiOverrideFactory.java | 10 ++++ .../ParDoSingleViaMultiOverrideFactory.java | 12 ++++- .../direct/TestStreamEvaluatorFactory.java | 7 +++ .../runners/direct/ViewEvaluatorFactory.java | 8 +++ .../direct/WriteWithShardingFactory.java | 10 ++++ .../DirectGroupByKeyOverrideFactoryTest.java | 51 ++++++++++++++++++++ .../direct/ParDoMultiOverrideFactoryTest.java | 45 +++++++++++++++++ .../ParDoSingleViaMultiOverrideFactoryTest.java | 45 +++++++++++++++++ .../direct/TestStreamEvaluatorFactoryTest.java | 11 +++++ .../direct/ViewEvaluatorFactoryTest.java | 9 ++++ .../direct/WriteWithShardingFactoryTest.java | 9 ++++ .../sdk/runners/PTransformOverrideFactory.java | 8 +++ 14 files changed, 244 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
