This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit ec55000f2686aae9856c53863cf70b85bc1ed38d
Merge: 8c8b7c3 efd261a
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Wed Dec 12 13:02:10 2018 +0100
Merge pull request #7078 from [BEAM-6094] External portable BeamPython.
[BEAM-6094] Implement external environment for portable BeamPython.
.../fn-execution/src/main/proto/beam_fn_api.proto | 20 ++
.../pipeline/src/main/proto/beam_runner_api.proto | 6 +
.../FlinkDefaultExecutableStageContext.java | 3 +
...actory.java => ExternalEnvironmentFactory.java} | 116 +++----
.../environment/ProcessEnvironmentFactory.java | 2 +-
sdks/python/apache_beam/pipeline.py | 9 +-
sdks/python/apache_beam/portability/python_urns.py | 16 +
.../python/apache_beam/runners/pipeline_context.py | 2 +-
.../runners/portability/flink_runner_test.py | 3 +-
.../runners/portability/fn_api_runner.py | 376 ++++++++++++++-------
.../runners/portability/fn_api_runner_test.py | 19 +-
.../portability/fn_api_runner_transforms.py | 48 ++-
.../runners/portability/local_job_service.py | 25 +-
.../runners/portability/local_job_service_main.py | 4 +-
.../runners/portability/portable_runner.py | 120 +++++--
.../runners/portability/portable_runner_test.py | 43 ++-
.../apache_beam/runners/worker/sdk_worker.py | 8 +-
.../runners/worker/worker_id_interceptor.py | 5 +-
18 files changed, 560 insertions(+), 265 deletions(-)
