You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/12/19 22:53:14 UTC
[beam] 01/01: Merge pull request #4064 from
chamikaramj/sdf_direct_runner_3
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3c81b41ff53ab890fd0c4d31d6fa1b157d9c0d81
Merge: 157787e 5443406
Author: Chamikara Jayalath <ch...@google.com>
AuthorDate: Tue Dec 19 14:53:10 2017 -0800
Merge pull request #4064 from chamikaramj/sdf_direct_runner_3
[BEAM-1630] Adds support for processing Splittable DoFns using DirectRunner.
.../apache_beam/examples/snippets/snippets_test.py | 4 +-
sdks/python/apache_beam/io/filebasedsource.py | 2 +-
sdks/python/apache_beam/io/iobase.py | 15 +-
sdks/python/apache_beam/io/range_trackers.py | 44 +--
sdks/python/apache_beam/io/range_trackers_test.py | 37 ---
sdks/python/apache_beam/io/restriction_trackers.py | 131 ++++++++
.../apache_beam/io/restriction_trackers_test.py | 159 +++++++++
sdks/python/apache_beam/pipeline.py | 2 +-
sdks/python/apache_beam/pipeline_test.py | 14 +-
sdks/python/apache_beam/runners/common.pxd | 26 +-
sdks/python/apache_beam/runners/common.py | 158 +++++++--
.../apache_beam/runners/direct/direct_runner.py | 23 +-
sdks/python/apache_beam/runners/direct/executor.py | 3 +
.../runners/direct/sdf_direct_runner.py | 354 +++++++++++++++++++++
.../runners/direct/sdf_direct_runner_test.py | 235 ++++++++++++++
.../runners/direct/transform_evaluator.py | 102 +++++-
sdks/python/apache_beam/runners/sdf_common.py | 168 ++++++++++
sdks/python/apache_beam/transforms/core.py | 24 +-
18 files changed, 1354 insertions(+), 147 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.