You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by pv...@apache.org on 2025/05/14 20:09:07 UTC
(iceberg) branch main updated (c882e39823 -> 268661af25)

This is an automated email from the ASF dual-hosted git repository.

pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


    from c882e39823 Build: Bump io.netty:netty-buffer from 4.2.0.Final to 4.2.1.Final (#13028)
     add 268661af25 Flink: Add DynamicRecord / DynamicRecordInternal / DynamicRecordInternalSerializer (#12996)

No new revisions were added by this update.

Summary of changes:
 flink/v2.0/build.gradle                            |   3 +
 .../iceberg/flink/sink/dynamic/DynamicRecord.java  | 130 +++++++++
 .../flink/sink/dynamic/DynamicRecordInternal.java  | 166 ++++++++++++
 .../dynamic/DynamicRecordInternalSerializer.java   | 296 +++++++++++++++++++++
 .../sink/dynamic/DynamicRecordInternalType.java    |  96 +++++++
 .../flink/sink/dynamic/TableSerializerCache.java   | 135 ++++++++++
 .../DynamicRecordInternalSerializerTestBase.java   |  96 +++++++
 ...DynamicRecordInternalSerializerWriteSchema.java |  14 +-
 ...namicRecordInternalSerializerWriteSchemaId.java |  14 +-
 .../sink/dynamic/TestTableSerializerCache.java     | 124 +++++++++
 10 files changed, 1058 insertions(+), 16 deletions(-)
 create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecord.java
 create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternal.java
 create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalSerializer.java
 create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalType.java
 create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableSerializerCache.java
 create mode 100644 flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordInternalSerializerTestBase.java
 copy api/src/main/java/org/apache/iceberg/view/ViewRepresentation.java => flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchema.java (74%)
 copy api/src/main/java/org/apache/iceberg/view/ViewRepresentation.java => flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordInternalSerializerWriteSchemaId.java (73%)
 create mode 100644 flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableSerializerCache.java