You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2022/04/01 16:53:46 UTC
[beam] branch master updated (3f52ddd -> fc65763)
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%)