This closes #1373
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/abd9fb3d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/abd9fb3d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/abd9fb3d Branch: refs/heads/master Commit: abd9fb3d7ced120c4c307df601673e3a548cfa87 Parents: 15e93c5 67ce531 Author: Thomas Groh <[email protected]> Authored: Wed Nov 16 18:21:58 2016 -0800 Committer: Thomas Groh <[email protected]> Committed: Wed Nov 16 18:21:58 2016 -0800 ---------------------------------------------------------------------- .../direct/BoundedReadEvaluatorFactory.java | 28 ++++++++--------- .../beam/runners/direct/DirectRunner.java | 7 +++-- .../beam/runners/direct/EmptyInputProvider.java | 22 +++++++------- .../direct/ExecutorServiceParallelExecutor.java | 12 ++++---- .../beam/runners/direct/RootInputProvider.java | 16 ++++++---- .../runners/direct/RootProviderRegistry.java | 19 ++++++------ .../direct/TestStreamEvaluatorFactory.java | 23 +++++++------- .../direct/TransformEvaluatorRegistry.java | 5 +-- .../direct/UnboundedReadEvaluatorFactory.java | 32 +++++++++++--------- 9 files changed, 85 insertions(+), 79 deletions(-) ----------------------------------------------------------------------
