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