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 3f52ddd [BEAM-14153] Reshuffled Row Coder PCollection used as Side
Input cause encoder issues. (#17147)
add 30ebe10 Revert "Revert "[BEAM-14038] Auto-startup for Python
expansion service. (#17035)""
add 0878d71 Skip failing test for now.
add fc65763 Merge pull request #17235 [BEAM-14148] Roll
PyExpansionService forward, skipping flaky test for now.
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} | 34 +++---
settings.gradle.kts | 1 +
7 files changed, 386 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}
(56%)
