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
