You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/08/09 06:12:52 UTC
[2/2] beam git commit: This closes #3667
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(+)
----------------------------------------------------------------------