This closes #754
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/23fa61ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/23fa61ce Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/23fa61ce Branch: refs/heads/master Commit: 23fa61ce0ce91371134b54618d2fc6ba0c84ef30 Parents: 636b5f7 8e7963f Author: Kenneth Knowles <[email protected]> Authored: Wed Aug 3 17:45:46 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Wed Aug 3 17:45:46 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/CommittedResult.java | 23 ++- .../beam/runners/direct/CompletionCallback.java | 8 + .../beam/runners/direct/EvaluationContext.java | 11 +- .../direct/ExecutorServiceParallelExecutor.java | 163 ++++++++++++------- .../runners/direct/StepTransformResult.java | 20 ++- .../beam/runners/direct/TransformExecutor.java | 1 + .../beam/runners/direct/TransformResult.java | 11 ++ .../runners/direct/ViewEvaluatorFactory.java | 9 +- .../runners/direct/CommittedResultTest.java | 26 ++- .../runners/direct/EvaluationContextTest.java | 3 + .../runners/direct/StepTransformResultTest.java | 91 +++++++++++ .../runners/direct/TransformExecutorTest.java | 33 +++- .../runners/direct/WatermarkManagerTest.java | 11 +- 13 files changed, 336 insertions(+), 74 deletions(-) ----------------------------------------------------------------------
