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/06/24 04:28:00 UTC

[beam] branch nightly-refs/heads/master updated (52e1b3ff9e9 -> e94f33a49f3)

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 52e1b3ff9e9 Merge pull request #21723 Add several IOs to the typescript SDK.
     add ed5002db70a Correcting the regex for the Dataflow job name.
     add 78ec29eb903 Merge pull request #21932 from rszper/rszper-jobNameRegex
     add 56c6820754d Move wrapper class outside run()
     add 44cff50e324 Move model class outside of run() function in pytorch_language_modeling example #22001
     add dc0b5e40417 Fix issues with test ordering (#21986)
     add 84025311cd9 Canonicalize standard_coders.yaml booleans
     add d85a982d25b Merge pull request #21954: Canonicalize standard_coders.yaml booleans
     add 1851eef15c5 Followup fix FileIOTest.testMatchWatchForNewFiles flaky (#21877)
     add 90e64f732a9 Fix links for issue report (#22033)
     add e94f33a49f3 Merge pull request #21953 from Implement PubsubSchemaTransformMessageToRowFactory

No new revisions were added by this update.

Summary of changes:
 .../beam/model/fnexecution/v1/standard_coders.yaml |  46 +--
 scripts/ci/issue-report/generateReport.js          |   4 +-
 sdks/go/pkg/beam/runners/dataflow/dataflow_test.go |  82 ++---
 .../apache/beam/sdk/options/PipelineOptions.java   |   2 +-
 .../java/org/apache/beam/sdk/io/FileIOTest.java    | 105 +++++--
 .../PubsubSchemaTransformMessageToRowFactory.java  | 180 +++++++++++
 ...bsubSchemaTransformMessageToRowFactoryTest.java | 329 +++++++++++++++++++++
 .../apache/beam/sdk/io/gcp/storage/GcsMatchIT.java | 181 +++++++-----
 .../inference/pytorch_language_modeling.py         |  85 +++---
 .../clients/dataflow/dataflow_v1b3_messages.py     |   2 +-
 10 files changed, 799 insertions(+), 217 deletions(-)
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformMessageToRowFactory.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformMessageToRowFactoryTest.java