You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by vt...@apache.org on 2026/09/25 13:56:23 UTC

(beam) 01/01: Merge pull request #40267 from ahmedabu98/cp40229

This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a commit to branch release-2.77
in repository https://gitbox.apache.org/repos/asf/beam.git

commit fa94d9cbb7325c66c1c01d52dcf0cce3b5676c81
Merge: 670e12184a7 3c02f3371fd
Author: Vitaly Terentyev <vi...@gmail.com>
AuthorDate: Fri Sep 25 17:56:13 2026 +0400

    Merge pull request #40267 from ahmedabu98/cp40229
    
    Cherrypicking Iceberg CDC sink schematransform

 CHANGES.md                                         |   1 +
 .../IcebergWriteSchemaTransformProvider.java       | 360 ++++++++++-
 .../sdk/io/iceberg/cdc/sink/CdcWriteConfig.java    |   7 +-
 .../beam/sdk/io/iceberg/cdc/sink/WriteCdcRows.java |   5 +-
 .../IcebergSchemaTransformTranslationTest.java     |  27 +
 ...IcebergWriteSchemaTransformProviderCdcTest.java | 696 +++++++++++++++++++++
 .../sdk/io/iceberg/cdc/sink/AssignCdcKeysTest.java |   3 +-
 .../io/iceberg/cdc/sink/CdcWriteConfigTest.java    |   4 +-
 sdks/python/apache_beam/yaml/yaml_io.py            |  75 ++-
 9 files changed, 1160 insertions(+), 18 deletions(-)