This closes #2055
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fbaac0fc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fbaac0fc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fbaac0fc Branch: refs/heads/master Commit: fbaac0fc81d12ca63b35b0e1f9176660c5164275 Parents: 453e37b a9361fa Author: Thomas Groh <tg...@google.com> Authored: Wed Feb 22 09:36:18 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Feb 22 09:36:18 2017 -0800 ---------------------------------------------------------------------- .../SingleInputOutputOverrideFactory.java | 50 ++++++++ .../SingleInputOutputOverrideFactoryTest.java | 114 +++++++++++++++++++ ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 23 +--- .../direct/DirectGroupByKeyOverrideFactory.java | 22 +--- .../ParDoSingleViaMultiOverrideFactory.java | 24 +--- .../runners/direct/ViewEvaluatorFactory.java | 24 +--- .../DirectGroupByKeyOverrideFactoryTest.java | 8 +- .../ParDoSingleViaMultiOverrideFactoryTest.java | 3 +- 8 files changed, 180 insertions(+), 88 deletions(-) ----------------------------------------------------------------------
