beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [3/3] incubator-beam git commit: [BEAM-596] Replace DirectResult#awaitCompletion with waitUntilFinish
Date Sat, 15 Oct 2016 01:08:37 GMT
[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 <lcwik@google.com>
Authored: Fri Oct 14 17:21:46 2016 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message