This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 819e54c972c41a1ec4ae56b604fa052a5edc991f Merge: 812e98fac24 a7a6515cf3f Author: Kenneth Knowles <k...@apache.org> AuthorDate: Tue Apr 9 11:36:52 2024 -0400 Merge pull request #30797: Initial Iceberg Sink .github/workflows/IO_Iceberg.yml | 118 +++++++ sdks/java/io/iceberg/build.gradle | 98 ++++++ .../beam/io/iceberg/AppendFilesToTables.java | 102 ++++++ .../apache/beam/io/iceberg/AssignDestinations.java | 65 ++++ .../beam/io/iceberg/DynamicDestinations.java | 36 +++ .../apache/beam/io/iceberg/FileWriteResult.java | 203 ++++++++++++ .../beam/io/iceberg/IcebergCatalogConfig.java | 233 ++++++++++++++ .../apache/beam/io/iceberg/IcebergDestination.java | 65 ++++ .../java/org/apache/beam/io/iceberg/IcebergIO.java | 50 +++ .../beam/io/iceberg/IcebergTableCreateConfig.java | 50 +++ .../apache/beam/io/iceberg/IcebergWriteResult.java | 65 ++++ .../io/iceberg/OneTableDynamicDestinations.java | 65 ++++ .../apache/beam/io/iceberg/PropertyBuilder.java | 38 +++ .../org/apache/beam/io/iceberg/RecordWriter.java | 99 ++++++ .../java/org/apache/beam/io/iceberg/RowHelper.java | 100 ++++++ .../org/apache/beam/io/iceberg/SchemaHelper.java | 116 +++++++ .../beam/io/iceberg/WriteGroupedRowsToFiles.java | 103 ++++++ .../beam/io/iceberg/WriteToDestinations.java | 123 ++++++++ .../beam/io/iceberg/WriteUngroupedRowsToFiles.java | 350 +++++++++++++++++++++ .../org/apache/beam/io/iceberg/package-info.java | 20 ++ .../beam/io/iceberg/FileWriteResultTest.java | 147 +++++++++ .../apache/beam/io/iceberg/IcebergIOWriteTest.java | 293 +++++++++++++++++ .../org/apache/beam/io/iceberg/RowHelperTest.java | 128 ++++++++ .../apache/beam/io/iceberg/TestDataWarehouse.java | 146 +++++++++ .../org/apache/beam/io/iceberg/TestFixtures.java | 101 ++++++ settings.gradle.kts | 2 + 26 files changed, 2916 insertions(+)