Repository: incubator-beam Updated Branches: refs/heads/master 1283308e2 -> f6ad58d60
This closes #1201 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f6ad58d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f6ad58d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f6ad58d6 Branch: refs/heads/master Commit: f6ad58d60c400765237ef213d3c5236f7e5d2369 Parents: 1283308 bb66143 Author: Thomas Groh <tg...@google.com> Authored: Tue Nov 1 14:06:35 2016 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Tue Nov 1 14:06:35 2016 -0700 ---------------------------------------------------------------------- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 14 +++--- .../direct/DirectGroupByKeyOverrideFactory.java | 25 ++++------ .../GroupAlsoByWindowEvaluatorFactory.java | 1 - .../direct/PTransformOverrideFactory.java | 8 ++-- .../beam/runners/direct/ParDoEvaluator.java | 5 -- .../direct/ParDoMultiEvaluatorFactory.java | 1 - .../runners/direct/ParDoOverrideFactory.java | 14 +++--- .../direct/ParDoSingleEvaluatorFactory.java | 1 - .../direct/TestStreamEvaluatorFactory.java | 14 ++---- .../direct/UncommittedBundleOutputManager.java | 50 -------------------- .../runners/direct/ViewEvaluatorFactory.java | 19 +++----- .../direct/WriteWithShardingFactory.java | 15 ++---- .../beam/runners/direct/ParDoEvaluatorTest.java | 1 - .../direct/WriteWithShardingFactoryTest.java | 26 ++-------- 14 files changed, 47 insertions(+), 147 deletions(-) ----------------------------------------------------------------------
