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 <[email protected]> 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 "[email protected]" <[email protected]>.
