This is an automated email from the ASF dual-hosted git repository. vterentev pushed a change to branch release-2.68 in repository https://gitbox.apache.org/repos/asf/beam.git
from 24837171e67 Cherrypick #36063: [Java] Fix expensive OneOfType precondition messages by making them lazy (#36084) add 766a613a866 Update iceberg to 1.9.2 (#35981) new ed436b7c6fc Cherry pick #35981 (#36079) The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../IO_Iceberg_Integration_Tests.json | 2 +- .../IO_Iceberg_Integration_Tests_Dataflow.json | 2 +- ...Iceberg_Managed_Integration_Tests_Dataflow.json | 2 +- .github/trigger_files/beam_PostCommit_SQL.json | 2 +- CHANGES.md | 2 + build.gradle.kts | 3 + examples/java/build.gradle | 3 - examples/java/{sql => iceberg}/build.gradle | 77 ++++++-------------- .../iceberg}/IcebergBatchWriteExample.java | 2 +- .../iceberg}/IcebergRestCatalogCDCExample.java | 2 +- .../IcebergRestCatalogStreamingWriteExample.java | 2 +- .../examples/iceberg}/IcebergTaxiExamples.java | 2 +- sdks/java/extensions/sql/build.gradle | 7 -- sdks/java/extensions/sql/iceberg/build.gradle | 81 ++++++++++++++++++++++ .../sql/meta/provider/iceberg/IcebergCatalog.java | 0 .../provider/iceberg/IcebergCatalogRegistrar.java} | 12 ++-- .../sql/meta/provider/iceberg/IcebergFilter.java | 0 .../sql/meta/provider/iceberg/IcebergTable.java | 0 .../provider/iceberg/IcebergTableProvider.java | 0 .../sql/meta/provider/iceberg/package-info.java | 0 .../provider/iceberg/BeamSqlCliIcebergTest.java | 0 .../meta/provider/iceberg/IcebergFilterTest.java | 0 .../meta/provider/iceberg/IcebergReadWriteIT.java | 6 +- .../provider/iceberg/IcebergTableProviderTest.java | 0 .../meta/provider/iceberg}/PubsubToIcebergIT.java | 3 +- .../sql/meta/catalog/InMemoryCatalogRegistrar.java | 6 +- sdks/java/io/expansion-service/build.gradle | 15 ++-- sdks/java/io/iceberg/build.gradle | 12 ++-- .../sdk/io/iceberg/RecordWriterManagerTest.java | 40 +++++++++-- settings.gradle.kts | 4 ++ 30 files changed, 181 insertions(+), 106 deletions(-) copy examples/java/{sql => iceberg}/build.gradle (54%) rename examples/java/{src/main/java/org/apache/beam/examples/cookbook => iceberg/src/main/java/org/apache/beam/examples/iceberg}/IcebergBatchWriteExample.java (99%) rename examples/java/{src/main/java/org/apache/beam/examples/cookbook => iceberg/src/main/java/org/apache/beam/examples/iceberg}/IcebergRestCatalogCDCExample.java (99%) rename examples/java/{src/main/java/org/apache/beam/examples/cookbook => iceberg/src/main/java/org/apache/beam/examples/iceberg}/IcebergRestCatalogStreamingWriteExample.java (99%) rename examples/java/{src/main/java/org/apache/beam/examples/cookbook => iceberg/src/main/java/org/apache/beam/examples/iceberg}/IcebergTaxiExamples.java (99%) create mode 100644 sdks/java/extensions/sql/iceberg/build.gradle rename sdks/java/extensions/sql/{ => iceberg}/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergCatalog.java (100%) copy sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/InMemoryCatalogRegistrar.java => iceberg/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergCatalogRegistrar.java} (74%) rename sdks/java/extensions/sql/{ => iceberg}/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergFilter.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergTable.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergTableProvider.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/package-info.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/BeamSqlCliIcebergTest.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergFilterTest.java (100%) rename sdks/java/extensions/sql/{ => iceberg}/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergReadWriteIT.java (98%) rename sdks/java/extensions/sql/{ => iceberg}/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergTableProviderTest.java (100%) rename sdks/java/extensions/sql/{src/test/java/org/apache/beam/sdk/extensions/sql => iceberg/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg}/PubsubToIcebergIT.java (98%)