[mosaic] Support ARRAY and MAP type validation Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
diff --git a/paimon-mosaic/src/main/java/org/apache/paimon/format/mosaic/MosaicFileFormat.java b/paimon-mosaic/src/main/java/org/apache/paimon/format/mosaic/MosaicFileFormat.java index bff850a..00843ca 100644 --- a/paimon-mosaic/src/main/java/org/apache/paimon/format/mosaic/MosaicFileFormat.java +++ b/paimon-mosaic/src/main/java/org/apache/paimon/format/mosaic/MosaicFileFormat.java
@@ -209,8 +209,8 @@ @Override public Void visit(ArrayType arrayType) { - throw new UnsupportedOperationException( - "Mosaic file format does not support type ARRAY"); + arrayType.getElementType().accept(this); + return null; } @Override @@ -227,7 +227,9 @@ @Override public Void visit(MapType mapType) { - throw new UnsupportedOperationException("Mosaic file format does not support type MAP"); + mapType.getKeyType().accept(this); + mapType.getValueType().accept(this); + return null; } @Override
diff --git a/paimon-mosaic/src/test/java/org/apache/paimon/format/mosaic/MosaicFileFormatTest.java b/paimon-mosaic/src/test/java/org/apache/paimon/format/mosaic/MosaicFileFormatTest.java index 8e53164..df6fb38 100644 --- a/paimon-mosaic/src/test/java/org/apache/paimon/format/mosaic/MosaicFileFormatTest.java +++ b/paimon-mosaic/src/test/java/org/apache/paimon/format/mosaic/MosaicFileFormatTest.java
@@ -85,12 +85,17 @@ } @Test - void testValidateDataFieldsMapUnsupported() { + void testValidateDataFieldsArraySupported() { + MosaicFileFormat format = createFormat(); + RowType rowType = DataTypes.ROW(DataTypes.ARRAY(DataTypes.INT())); + format.validateDataFields(rowType); + } + + @Test + void testValidateDataFieldsMapSupported() { MosaicFileFormat format = createFormat(); RowType rowType = DataTypes.ROW(DataTypes.MAP(DataTypes.STRING(), DataTypes.INT())); - assertThatThrownBy(() -> format.validateDataFields(rowType)) - .isInstanceOf(UnsupportedOperationException.class) - .hasMessageContaining("MAP"); + format.validateDataFields(rowType); } @Test