You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/10/15 01:08:37 UTC
[3/3] incubator-beam git commit: [BEAM-596] Replace
DirectResult#awaitCompletion with waitUntilFinish
[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(-)
----------------------------------------------------------------------