This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f1e214712c8 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#32214)
add c9ad32ea8f4 [Managed Iceberg] Support writing to partitioned tables
(#32102)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../apache/beam/sdk/io/iceberg/RecordWriter.java | 75 ++++--
.../beam/sdk/io/iceberg/RecordWriterManager.java | 298 +++++++++++++++++++++
.../sdk/io/iceberg/WriteGroupedRowsToFiles.java | 49 ++--
.../sdk/io/iceberg/WriteUngroupedRowsToFiles.java | 164 +++---------
.../apache/beam/sdk/io/iceberg/IcebergIOIT.java | 285 +++++++++++---------
.../sdk/io/iceberg/RecordWriterManagerTest.java | 266 ++++++++++++++++++
.../beam/sdk/io/iceberg/TestDataWarehouse.java | 8 +-
8 files changed, 843 insertions(+), 303 deletions(-)
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriterManager.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/RecordWriterManagerTest.java
