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/11/13 04:40:35 UTC
[beam] branch nightly-refs/heads/master updated (4b96193250a -> aa0a35dabf9)
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 4b96193250a Remove TheNeuralBit from the pool of Python reviewers (#24108)
add b2d28a64bb0 Add TFX support in pydoc (#23960)
add 027fb142038 Bump cloud.google.com/go/bigtable from 1.17.0 to 1.18.0 in /sdks (#24113)
add 3a6fcc1ca4d disable (#24121)
add 9fcd20c3712 Implement PubsubRowToMessage transform (#23897)
add 836766ddb83 upgrade testcontainer dependency (#24123)
add 96f9da1ab65 More cleanup containers (#24105)
add 6557c91c794 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#24112)
add c2021bee1eb Bump google.golang.org/api from 0.102.0 to 0.103.0 in /sdks (#24049)
add 5d2dbf957e4 Update staging of Python wheels (#24114)
add 369e2ba8622 Add a ValidatesContainer integration test for use_sibling_sdk_workers (#24099)
add aa0a35dabf9 Fix checkArgument format string in TestStream (#24134)
No new revisions were added by this update.
Summary of changes:
.github/workflows/playground_examples_ci.yml | 10 +-
.../jenkins/job_CleanUpPrebuiltSDKImages.groovy | 2 +-
.../tools/stale_dataflow_prebuilt_image_cleaner.sh | 68 +-
sdks/go.mod | 24 +-
sdks/go.sum | 54 +-
.../go/test/integration/io/xlang/jdbc/jdbc_test.go | 5 +-
.../org/apache/beam/sdk/testing/TestStream.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 577 +++++++++++
.../sdk/io/gcp/pubsub/PubsubRowToMessageTest.java | 1085 ++++++++++++++++++++
.../apache_beam/examples/wordcount_it_test.py | 4 +
sdks/python/apache_beam/ml/inference/__init__.py | 5 +
.../apache_beam/runners/portability/stager.py | 20 +-
.../apache_beam/runners/portability/stager_test.py | 2 +
sdks/python/container/boot.go | 6 +-
sdks/python/setup.py | 2 +-
15 files changed, 1786 insertions(+), 80 deletions(-)
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubRowToMessageTest.java