You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/04/26 03:56:58 UTC
[beam] branch nightly-refs/heads/master updated (3f2e3c7c9ec -> 07f30d221e4)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 3f2e3c7c9ec [BEAM-13953] added documentation for BQ Storage Write API (#17391)
add 20e12969cd6 added tempLocation to test pipeline options
add 4fe1f5e779a using tempRoot for temp bucket location
add 249ea4074d5 small fixes
add 095682cc221 Merge pull request #17446: [BEAM-14356] fixing a postcommit test
add 52dd5a5effc [BEAM-14320] Update programming-guide w/Java GroupByKey example (#17369)
add a13d865395c Minor: Fix release script for `current` symlinks (#17457)
add 68b9100db4b Minor: fix typo (#17452)
add eedff4b996c Change return type for PytorchInferenceRunner (#17460)
add a936ef88985 [BEAM-13608] JmsIO dynamic topics feature (#17163)
add 81c5b0806b9 [BEAM-14343] Allow expansion service override in ExternalPythonTransform
add a17d560d3e0 update
add bafc5fa2378 allows remote host
add 4c4ca1b539d improve compatibility with python rowcoder
add 43f11738994 add test
add 07f30d221e4 Merge pull request #17418 from ihji/BEAM-14343
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 14 +-
.../src/main/scripts/build_release_candidate.sh | 4 +-
.../extensions/python/ExternalPythonTransform.java | 156 +++++++++++------
.../python/ExternalPythonTransformTest.java | 36 ++++
.../beam/sdk/io/gcp/bigquery/BigQueryIOJsonIT.java | 10 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 191 ++++++++++++++++-----
.../jms/{package-info.java => JmsIOException.java} | 14 +-
...faultAutoscaler.java => TextMessageMapper.java} | 27 +--
.../apache/beam/sdk/io/jms/WriteJmsResult.java} | 53 +++---
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 122 ++++++++++++-
sdks/python/apache_beam/ml/inference/pytorch.py | 2 +-
sdks/python/apache_beam/transforms/core.py | 2 +-
.../content/en/documentation/programming-guide.md | 12 ++
13 files changed, 495 insertions(+), 148 deletions(-)
copy sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/{package-info.java => JmsIOException.java} (79%)
copy sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/{DefaultAutoscaler.java => TextMessageMapper.java} (56%)
copy sdks/java/io/{google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteResult.java => jms/src/main/java/org/apache/beam/sdk/io/jms/WriteJmsResult.java} (53%)