This closes #260
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d5303d8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4d5303d8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4d5303d8 Branch: refs/heads/master Commit: 4d5303d8a8cc175cecf3686347e7d7465f902a9e Parents: baae901 2618aa6 Author: Kenneth Knowles <k...@google.com> Authored: Thu Apr 28 17:50:38 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Apr 28 17:50:38 2016 -0700 ---------------------------------------------------------------------- .../sdk/runners/inprocess/CommittedResult.java | 47 ++++++++++++ .../runners/inprocess/CompletionCallback.java | 2 +- .../ExecutorServiceParallelExecutor.java | 16 ++-- .../inprocess/InProcessEvaluationContext.java | 4 +- .../runners/inprocess/TransformExecutor.java | 4 +- .../runners/inprocess/CommittedResultTest.java | 78 ++++++++++++++++++++ .../InProcessEvaluationContextTest.java | 4 +- .../inprocess/TransformExecutorTest.java | 4 +- 8 files changed, 142 insertions(+), 17 deletions(-) ----------------------------------------------------------------------