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(+)
