This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 464db0171e9 [Python] Round float seconds to the nearest microsecond in
Duration (#40236)
add 5a218f6c241 assign reviewers immediately when PR is marked ready for
review (#40400)
add dedbf9c8522 Prevent CommitTooLargeException in OrderedEventProcessor
on duplicate floods (#40242)
add 976f0522030 Deprecate ParquetIO.withProjection (#40043)
add 041bd00e4f6 Blog post: Beam modernization at project 10-year mark
(#40368)
add 7711c5345ad bump code coverage to v7 (#40416)
add f6c9c882e88 Bump github.com/moby/moby/api from 1.56.0 to 1.56.1 in
/sdks (#40407)
add 9f78aaf6fee Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#40411)
add 7083a3ff0ce Bump github.com/moby/moby/client from 0.6.0 to 0.6.1 in
/sdks (#40408)
add d22c3c32fdb Bump google.golang.org/api from 0.299.0 to 0.300.0 in
/sdks (#40410)
add e2c9256725c [KafkaIO] Add `with_gcp_adc` and `num_partitions` options
to Kafka SchemaTransforms and YAML (#40181)
add 662b91c3d62 Fix exception masking in FileSystems.matchSingleFileSpec
add 782b97c7cdc Replace Mockito FileSystem mock with native FakeFileSystem
in tests
add c7a9bb77f17 Merge pull request #40109: Fix exception masking in
FileSystems.matchSingleFileSpec
add 261f05f142b [Python] Fix LogElements crash on global window timestamps
(#40332)
add c74609d71ee [Python] Support Lakehouse runtime catalog tables in
ReadFromBigQuery… (#40225)
No new revisions were added by this update.
Summary of changes:
.github/workflows/beam_PreCommit_Java.yml | 2 +-
.github/workflows/beam_PreCommit_Java_Dataflow.yml | 2 +-
.../workflows/beam_PreCommit_Python_Coverage.yml | 2 +-
.github/workflows/beam_PreCommit_SQL.yml | 2 +-
.github/workflows/go_tests.yml | 2 +-
CHANGES.md | 1 +
scripts/ci/pr-bot/README.md | 1 +
scripts/ci/pr-bot/processNewPrs.ts | 19 +-
scripts/ci/pr-bot/processPrUpdate.ts | 10 +-
scripts/ci/pr-bot/shared/checks.ts | 7 +-
sdks/go.mod | 32 +--
sdks/go.sum | 68 +++---
.../java/org/apache/beam/sdk/io/FileSystems.java | 11 +-
.../org/apache/beam/sdk/io/FileSystemsTest.java | 86 ++++++++
.../ordered/GlobalSequencesProcessorDoFn.java | 2 +
.../sdk/extensions/ordered/ProcessingState.java | 4 +
.../beam/sdk/extensions/ordered/ProcessorDoFn.java | 20 +-
.../ordered/SequencePerKeyProcessorDoFn.java | 2 +
.../OrderedEventProcessorPerKeySequenceTest.java | 48 ++++
.../KafkaReadSchemaTransformConfiguration.java | 19 ++
.../io/kafka/KafkaReadSchemaTransformProvider.java | 28 ++-
.../kafka/KafkaWriteSchemaTransformProvider.java | 52 +++--
.../KafkaReadSchemaTransformProviderTest.java | 64 +++++-
.../KafkaWriteSchemaTransformProviderTest.java | 13 +-
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 52 +++--
sdks/python/apache_beam/io/gcp/bigquery.py | 46 ++--
sdks/python/apache_beam/io/gcp/bigquery_test.py | 52 +++++
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 100 +++++++--
.../apache_beam/io/gcp/bigquery_tools_test.py | 63 ++++++
sdks/python/apache_beam/transforms/util.py | 7 +-
sdks/python/apache_beam/transforms/util_test.py | 8 +
sdks/python/apache_beam/yaml/standard_io.yaml | 3 +
.../site/content/en/blog/beam-modernization-10y.md | 243 +++++++++++++++++++++
33 files changed, 930 insertions(+), 141 deletions(-)
create mode 100644 website/www/site/content/en/blog/beam-modernization-10y.md
