This closes #1547
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cc28f0cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cc28f0cb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cc28f0cb Branch: refs/heads/master Commit: cc28f0cb4c44169f933475ae29a32599024d3a1f Parents: 217c29b 3f227a0 Author: Thomas Groh <tg...@google.com> Authored: Fri Dec 16 14:21:50 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Fri Dec 16 14:21:50 2016 -0800 ---------------------------------------------------------------------- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 7 ++-- .../direct/DirectGroupByKeyOverrideFactory.java | 3 +- .../beam/runners/direct/DirectRunner.java | 7 +++- .../direct/PTransformOverrideFactory.java | 35 ----------------- .../direct/ParDoMultiOverrideFactory.java | 9 +++-- .../ParDoSingleViaMultiOverrideFactory.java | 11 +++--- .../direct/TestStreamEvaluatorFactory.java | 5 ++- .../runners/direct/ViewEvaluatorFactory.java | 4 +- .../direct/WriteWithShardingFactory.java | 6 ++- .../direct/WriteWithShardingFactoryTest.java | 4 +- .../beam/sdk/annotations/Experimental.java | 5 ++- .../sdk/runners/PTransformOverrideFactory.java | 41 ++++++++++++++++++++ 12 files changed, 80 insertions(+), 57 deletions(-) ----------------------------------------------------------------------