[BEAM-596] Replace DirectResult#awaitCompletion with waitUntilFinish This closes #1098
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b8e6eea6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b8e6eea6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b8e6eea6 Branch: refs/heads/master Commit: b8e6eea691b48e14c4e2c3e84609d750769e09ee Parents: c2c650a 06bd074 Author: Luke Cwik <lc...@google.com> Authored: Fri Oct 14 17:21:46 2016 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Fri Oct 14 17:21:46 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/CompletionCallback.java | 4 +- .../beam/runners/direct/DirectOptions.java | 4 +- .../beam/runners/direct/DirectRunner.java | 27 +++++++------ .../direct/ExecutorServiceParallelExecutor.java | 40 ++++++++++---------- .../beam/runners/direct/PipelineExecutor.java | 2 +- .../beam/runners/direct/TransformExecutor.java | 10 ++--- .../beam/runners/direct/DirectRunnerTest.java | 6 +-- .../runners/direct/TransformExecutorTest.java | 16 ++++---- 8 files changed, 54 insertions(+), 55 deletions(-) ----------------------------------------------------------------------