Repository: incubator-beam Updated Branches: refs/heads/master 643cf63d5 -> 05c6c2749
Closes #937 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/05c6c274 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/05c6c274 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/05c6c274 Branch: refs/heads/master Commit: 05c6c2749f667c9e90569dd2933b17f4385f931c Parents: 643cf63 c2970aa Author: bchambers <bchamb...@google.com> Authored: Mon Sep 12 09:53:16 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Sep 12 09:53:16 2016 -0700 ---------------------------------------------------------------------- .../direct/BoundedReadEvaluatorFactory.java | 30 ++++---- .../beam/runners/direct/DirectRunner.java | 2 +- .../direct/ExecutorServiceParallelExecutor.java | 1 - .../runners/direct/FlattenEvaluatorFactory.java | 15 ++-- .../GroupAlsoByWindowEvaluatorFactory.java | 14 ++-- .../direct/GroupByKeyOnlyEvaluatorFactory.java | 14 ++-- .../direct/ParDoMultiEvaluatorFactory.java | 13 ++-- .../direct/ParDoSingleEvaluatorFactory.java | 13 ++-- .../direct/TestStreamEvaluatorFactory.java | 13 ++-- .../direct/TransformEvaluatorFactory.java | 22 +++--- .../direct/TransformEvaluatorRegistry.java | 37 ++++------ .../beam/runners/direct/TransformExecutor.java | 8 +-- .../direct/UnboundedReadEvaluatorFactory.java | 46 ++++++------ .../runners/direct/ViewEvaluatorFactory.java | 14 ++-- .../runners/direct/WindowEvaluatorFactory.java | 14 ++-- .../direct/BoundedReadEvaluatorFactoryTest.java | 16 ++--- .../direct/FlattenEvaluatorFactoryTest.java | 15 ++-- .../direct/GroupByKeyEvaluatorFactoryTest.java | 5 +- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 4 +- .../direct/ParDoMultiEvaluatorFactoryTest.java | 16 ++--- .../direct/ParDoSingleEvaluatorFactoryTest.java | 16 ++--- .../direct/TestStreamEvaluatorFactoryTest.java | 35 +++++---- .../runners/direct/TransformExecutorTest.java | 75 +++++++------------- .../UnboundedReadEvaluatorFactoryTest.java | 24 +++---- .../direct/ViewEvaluatorFactoryTest.java | 4 +- .../direct/WindowEvaluatorFactoryTest.java | 6 +- 26 files changed, 231 insertions(+), 241 deletions(-) ----------------------------------------------------------------------
