This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6da5fa6 Populate environment capabilities in v1beta3 protos. (#17042)
add 0510cec [BEAM-14038] Auto-startup for Python expansion service.
(#17035)
No new revisions were added by this update.
Summary of changes:
.../java/extensions/{arrow => python}/build.gradle | 14 +--
.../extensions/python/ExternalPythonTransform.java | 110 +++++++++++++++++
.../beam/sdk/extensions/python/PythonService.java | 132 +++++++++++++++++++++
.../beam/sdk/extensions/python}/package-info.java | 4 +-
.../sdk/extensions/python/bootstrap_beam_venv.py | 115 ++++++++++++++++++
.../python/ExternalPythonTransformTest.java} | 32 ++---
settings.gradle.kts | 1 +
7 files changed, 384 insertions(+), 24 deletions(-)
copy sdks/java/extensions/{arrow => python}/build.gradle (78%)
create mode 100644
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/ExternalPythonTransform.java
create mode 100644
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/PythonService.java
copy
{examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/options
=>
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python}/package-info.java
(87%)
create mode 100644
sdks/java/extensions/python/src/main/resources/org/apache/beam/sdk/extensions/python/bootstrap_beam_venv.py
copy
sdks/java/extensions/{euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/translate/TimestampExtractTransformTest.java
=>
python/src/test/java/org/apache/beam/sdk/extensions/python/ExternalPythonTransformTest.java}
(57%)
