Repository: incubator-beam Updated Branches: refs/heads/python-sdk 93a95d68b -> aa603872c
Closes #1240 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aa603872 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aa603872 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/aa603872 Branch: refs/heads/python-sdk Commit: aa603872c5cb79c6e9a4c12f0a49d68a942a6007 Parents: 93a95d6 d021e9c Author: Robert Bradshaw <rober...@google.com> Authored: Mon Nov 7 17:56:49 2016 -0800 Committer: Robert Bradshaw <rober...@google.com> Committed: Mon Nov 7 17:56:49 2016 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/io/filebasedsource.py | 7 +- sdks/python/apache_beam/io/source_test_utils.py | 14 +- sdks/python/apache_beam/pipeline_test.py | 99 +--- sdks/python/apache_beam/runners/__init__.py | 3 +- .../apache_beam/runners/direct/__init__.py | 19 + .../runners/direct/bundle_factory.py | 102 ++++ sdks/python/apache_beam/runners/direct/clock.py | 50 ++ .../consumer_tracking_pipeline_visitor.py | 59 ++ .../consumer_tracking_pipeline_visitor_test.py | 122 ++++ .../apache_beam/runners/direct/direct_runner.py | 158 ++++++ .../runners/direct/evaluation_context.py | 272 +++++++++ .../apache_beam/runners/direct/executor.py | 550 +++++++++++++++++++ .../runners/direct/transform_evaluator.py | 542 ++++++++++++++++++ .../runners/direct/transform_result.py | 60 ++ .../runners/direct/watermark_manager.py | 224 ++++++++ .../python/apache_beam/runners/direct_runner.py | 308 ----------- .../apache_beam/runners/inprocess/__init__.py | 19 - .../runners/inprocess/bundle_factory.py | 102 ---- .../apache_beam/runners/inprocess/clock.py | 50 -- .../consumer_tracking_pipeline_visitor.py | 59 -- .../consumer_tracking_pipeline_visitor_test.py | 122 ---- .../inprocess/inprocess_evaluation_context.py | 272 --------- .../runners/inprocess/inprocess_executor.py | 550 ------------------- .../runners/inprocess/inprocess_runner.py | 142 ----- .../runners/inprocess/inprocess_runner_test.py | 121 ---- .../inprocess/inprocess_transform_result.py | 60 -- .../inprocess/inprocess_watermark_manager.py | 224 -------- .../runners/inprocess/transform_evaluator.py | 542 ------------------ sdks/python/apache_beam/runners/runner.py | 5 +- sdks/python/tox.ini | 1 + 30 files changed, 2210 insertions(+), 2648 deletions(-) ----------------------------------------------------------------------
