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/22 12:46:23 UTC

(beam) 01/01: Merge pull request #40212 from ahmedabu98/cp40030

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 e37c9083271288b5a6e412aef5dfd5814bbcd303
Merge: 1f44d891e7c 33e2013c948
Author: Vitaly Terentyev <vi...@gmail.com>
AuthorDate: Tue Sep 22 16:46:14 2026 +0400

    Merge pull request #40212 from ahmedabu98/cp40030
    
    Cherry-picking assign CDC keys stage

 .../sdk/io/iceberg/cdc/sink/AssignCdcKeys.java     |  392 ++++++
 .../iceberg/cdc/sink/SingleTableDestinations.java  |   79 ++
 .../sdk/io/iceberg/cdc/sink/AssignCdcKeysTest.java | 1244 ++++++++++++++++++++
 .../sdk/io/iceberg/cdc/sink/CdcSinkTestUtils.java  |   59 +
 4 files changed, 1774 insertions(+)