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 7d79fa18b6 Build: Bump hadoop from 3.4.2 to 3.4.3. (#15431)
add 4543e03b4a Flink: Support Variant to Flink 2.1 (#15265)
No new revisions were added by this update.
Summary of changes:
.../apache/iceberg/variants/VariantTestHelper.java | 142 ++++++++++++++++
.../org/apache/iceberg/flink/FlinkTypeToType.java | 6 +
.../org/apache/iceberg/flink/TypeToFlinkType.java | 6 +
.../iceberg/flink/data/FlinkParquetReaders.java | 40 +++++
.../iceberg/flink/data/FlinkParquetWriters.java | 65 ++++++++
.../flink/data/ParquetWithFlinkSchemaVisitor.java | 19 +++
.../org/apache/iceberg/flink/RowDataConverter.java | 15 ++
.../apache/iceberg/flink/TestFlinkVariantType.java | 128 ++++++++++++++
.../java/org/apache/iceberg/flink/TestHelpers.java | 61 +++++++
.../iceberg/flink/data/TestFlinkParquetWriter.java | 5 +
.../iceberg/flink/data/TestFlinkVariants.java | 183 +++++++++++++++++++++
.../iceberg/spark/data/TestSparkVariants.java | 87 +---------
12 files changed, 677 insertions(+), 80 deletions(-)
create mode 100644
core/src/test/java/org/apache/iceberg/variants/VariantTestHelper.java
create mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/TestFlinkVariantType.java
create mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkVariants.java
