This is an automated email from the ASF dual-hosted git repository.
Amar3tto pushed a change to branch release-2.77
in repository https://gitbox.apache.org/repos/asf/beam.git
from e89883ac6af Addfiles wiring provider (#40150) (#40199)
add 16ca03cf797 write deltas
add 310e624655e destination shard
add 89f695d32f6 cleanup
add fbdbadc6bc8 address comments
add 311ca949376 use serializable table
add 1f44d891e7c Merge pull request #40211 from ahmedabu98/cp40031
No new revisions were added by this update.
Summary of changes:
.../sdk/io/iceberg/cdc/sink/ShardDeltaFiles.java | 87 +++
.../beam/sdk/io/iceberg/cdc/sink/WriteDeltas.java | 204 +++++
.../io/iceberg/cdc/sink/ShardDeltaFilesTest.java | 185 +++++
.../sdk/io/iceberg/cdc/sink/WriteDeltasTest.java | 824 +++++++++++++++++++++
4 files changed, 1300 insertions(+)
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/sink/ShardDeltaFiles.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/sink/WriteDeltas.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/ShardDeltaFilesTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/WriteDeltasTest.java
