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 bdf650a75b5 Support TensorRT 10 and later in
TensorRTEngineHandlerNumPy (#39922)
add 720fa2fcb5f Track ReplaceTokens values as processResources inputs
(#40133)
add 333a7787e94 Implement Iceberg Side-Input Table Cache Integration with
Fallback (#40080)
add 808376b1cae Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#40138)
add 006cd7b98d5 normalize Spanner CDC (#40040)
add 405c084045e Bump cloud.google.com/go/spanner from 1.95.0 to 1.95.1 in
/sdks (#40136)
add 2bd256532b5 AddFiles: create the table from the file schemas when it
does not exist (#40124)
add 876596e1afd Merge pull request #37731: RedisIO support PCollection of
<byte[], byte[]>
add 480a438cc80 Update Dataflow container versions to 20260916 (#40145)
add 4cfde9e6cbd [CI] Fix label race condition between LabelPrs and
pr-bot-pr-updates (#40141)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.github/workflows/label_prs.yml | 3 +
.github/workflows/pr-bot-pr-updates.yml | 7 +-
.../google-cloud-dataflow-java/arm/build.gradle | 5 +-
runners/google-cloud-dataflow-java/build.gradle | 10 +-
scripts/ci/pr-bot/processPrUpdate.ts | 3 +-
sdks/go.mod | 8 +-
sdks/go.sum | 16 +-
sdks/java/extensions/sql/jdbc/build.gradle | 5 +-
.../beam/sdk/io/gcp/spanner/ReadSpannerSchema.java | 73 ++-
...erChangestreamsReadSchemaTransformProvider.java | 50 +-
.../iceberg/AssignDestinationsAndPartitions.java | 75 ++-
.../beam/sdk/io/iceberg/CommitSchemaOnce.java | 89 ++++
.../beam/sdk/io/iceberg/CommitSchemaUnion.java | 513 ++++++++++++++-----
.../java/org/apache/beam/sdk/io/iceberg/Pins.java | 5 +
.../beam/sdk/io/iceberg/RecordWriterManager.java | 56 ++-
.../sdk/io/iceberg/WriteDirectRowsToFiles.java | 44 +-
.../sdk/io/iceberg/WriteGroupedRowsToFiles.java | 47 +-
.../io/iceberg/WritePartitionedRowsToFiles.java | 66 ++-
.../beam/sdk/io/iceberg/WriteToDestinations.java | 31 +-
.../beam/sdk/io/iceberg/WriteToPartitions.java | 21 +-
.../sdk/io/iceberg/WriteUngroupedRowsToFiles.java | 72 ++-
.../AssignDestinationsAndPartitionsTest.java | 200 ++++++++
.../beam/sdk/io/iceberg/CommitSchemaOnceTest.java | 157 ++++++
.../beam/sdk/io/iceberg/CommitSchemaUnionTest.java | 516 +++++++++++++++++++
.../sdk/io/iceberg/RecordWriterManagerTest.java | 104 ++++
.../sdk/io/iceberg/WriteWithMetadataViewTest.java | 397 +++++++++++++++
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 547 +++++++++++++++++----
.../org/apache/beam/sdk/io/redis/RedisIOTest.java | 292 ++++++++++-
sdks/java/maven-archetypes/examples/build.gradle | 5 +-
.../maven-archetypes/gcp-bom-examples/build.gradle | 5 +-
sdks/java/maven-archetypes/starter/build.gradle | 5 +-
sdks/python/apache_beam/yaml/standard_io.yaml | 21 +
33 files changed, 3101 insertions(+), 349 deletions(-)
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/CommitSchemaOnce.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/AssignDestinationsAndPartitionsTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/CommitSchemaOnceTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/WriteWithMetadataViewTest.java
