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 51ea3f080c2 Merge pull request #39990: Refactor: delete dead
SplitAndSizeRestrictions handling from FnApiDoFnRunner
add 6c9dfa584ac [Iceberg] CDC config and writer (#39997)
No new revisions were added by this update.
Summary of changes:
.../sdk/io/iceberg/cdc/sink/CdcWriteConfig.java | 235 +++++
.../io/iceberg/cdc/sink/RecordDeltaTaskWriter.java | 506 +++++++++
.../sdk/io/iceberg/cdc/sink/CdcSinkTestUtils.java | 193 ++++
.../io/iceberg/cdc/sink/CdcWriteConfigTest.java | 226 ++++
.../cdc/sink/RecordDeltaTaskWriterTest.java | 1079 ++++++++++++++++++++
5 files changed, 2239 insertions(+)
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/sink/CdcWriteConfig.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/sink/RecordDeltaTaskWriter.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/CdcSinkTestUtils.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/CdcWriteConfigTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/RecordDeltaTaskWriterTest.java
