Skip to content

Commit 46e9a9a

Browse files
committed
feat: add MAP type support for first level
1 parent 3709e71 commit 46e9a9a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

spark/src/test/scala/org/apache/comet/parquet/ParquetReadSuite.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -107,19 +107,19 @@ abstract class ParquetReadSuite extends CometTestBase {
107107
Seq(
108108
StructField("f1", DecimalType.SYSTEM_DEFAULT),
109109
StructField("f2", StringType))) -> usingNativeIcebergCompat,
110-
MapType(keyType = LongType, valueType = DateType) -> false,
110+
MapType(keyType = LongType, valueType = DateType) -> usingNativeIcebergCompat,
111111
StructType(
112112
Seq(
113113
StructField("f1", ByteType),
114114
StructField("f2", StringType))) -> usingNativeIcebergCompat,
115-
MapType(keyType = IntegerType, valueType = BinaryType) -> false).foreach {
116-
case (dt, expected) =>
115+
MapType(keyType = IntegerType, valueType = BinaryType) -> usingNativeIcebergCompat)
116+
.foreach { case (dt, expected) =>
117117
assert(CometScanExec.isTypeSupported(dt) == expected)
118118
// usingDataFusionParquetExec does not support CometBatchScanExec yet
119119
if (!usingDataFusionParquetExec(conf)) {
120120
assert(CometBatchScanExec.isTypeSupported(dt) == expected)
121121
}
122-
}
122+
}
123123
}
124124

125125
test("unsupported Spark schema") {

0 commit comments

Comments
 (0)