You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/11/27 23:03:49 UTC
[beam] 01/01: Merge pull request #4151 from tgroh/bundle_executor
This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit d8ca4c4b211c89d427ecf35791b33e4c7526a74b
Merge: 3b79b62 b868743
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Mon Nov 27 15:03:45 2017 -0800
Merge pull request #4151 from tgroh/bundle_executor
[BEAM-2899] Decompose Direct Execution Components
.../beam/runners/direct/BundleProcessor.java | 33 ++
.../apache/beam/runners/direct/DirectRunner.java | 6 +-
.../direct/ExecutorServiceParallelExecutor.java | 424 ++++-----------------
.../beam/runners/direct/PipelineExecutor.java | 10 +-
.../beam/runners/direct/QuiescenceDriver.java | 333 ++++++++++++++++
.../apache/beam/runners/local/ExecutionDriver.java | 45 +++
.../runners/local/PipelineMessageReceiver.java | 44 +++
.../src/main/resources/beam/findbugs-filter.xml | 10 +-
8 files changed, 542 insertions(+), 363 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.