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