This closes #3667
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fb85d84d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fb85d84d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fb85d84d Branch: refs/heads/master Commit: fb85d84dcb6cdbf87e881117a359eab27d8fd935 Parents: 9ed2cf4 76db0aa Author: Ahmet Altay <al...@google.com> Authored: Tue Aug 8 23:12:37 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Tue Aug 8 23:12:37 2017 -0700 ---------------------------------------------------------------------- .../runners/experimental/__init__.py | 16 +++ .../experimental/python_rpc_direct/__init__.py | 22 ++++ .../python_rpc_direct_runner.py | 111 +++++++++++++++++++ .../experimental/python_rpc_direct/server.py | 111 +++++++++++++++++++ sdks/python/apache_beam/runners/job/__init__.py | 16 +++ sdks/python/apache_beam/runners/job/manager.py | 52 +++++++++ sdks/python/apache_beam/runners/job/utils.py | 32 ++++++ sdks/python/apache_beam/runners/runner.py | 6 + 8 files changed, 366 insertions(+) ----------------------------------------------------------------------