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 39fadf1a5dd61a802fdb8b36cf8d897f4258834c
Merge: fa9b8e482d9 cb3e637f883
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Thu Sep 24 00:03:13 2026 +0400

    Merge pull request #40231 from ahmedabu98/cp40161
    
    Cherry-picking Iceberg CDC sink Java API layer

 .../org/apache/beam/sdk/io/iceberg/IcebergIO.java  |   18 +
 .../beam/sdk/io/iceberg/IcebergWriteResult.java    |   87 ++
 .../beam/sdk/io/iceberg/cdc/sink/WriteCdcRows.java |  550 +++++++
 .../beam/sdk/io/iceberg/cdc/sink/package-info.java |  233 ++-
 .../iceberg/cdc/sink/WriteCdcRowsReadBackTest.java | 1526 ++++++++++++++++++++
 .../sdk/io/iceberg/cdc/sink/WriteCdcRowsTest.java  | 1499 +++++++++++++++++++
 6 files changed, 3911 insertions(+), 2 deletions(-)

Reply via email to