Skip to content

Commit 83be2ec

Browse files
committed
feat: add read array support
1 parent 1239f54 commit 83be2ec

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

spark/src/test/scala/org/apache/comet/exec/CometNativeReaderSuite.scala

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -31,17 +31,19 @@ import org.apache.comet.CometConf
3131
class CometNativeReaderSuite extends CometTestBase with AdaptiveSparkPlanHelper {
3232
override protected def test(testName: String, testTags: Tag*)(testFun: => Any)(implicit
3333
pos: Position): Unit = {
34-
Seq(CometConf.SCAN_NATIVE_DATAFUSION, CometConf.SCAN_NATIVE_ICEBERG_COMPAT).foreach(scan =>
35-
super.test(s"$testName - $scan", testTags: _*) {
36-
withSQLConf(
37-
CometConf.COMET_EXEC_ENABLED.key -> "true",
38-
SQLConf.USE_V1_SOURCE_LIST.key -> "parquet",
39-
CometConf.COMET_ENABLED.key -> "true",
40-
CometConf.COMET_EXPLAIN_FALLBACK_ENABLED.key -> "false",
41-
CometConf.COMET_NATIVE_SCAN_IMPL.key -> scan) {
42-
testFun
43-
}
44-
})
34+
// TODO: Enable Iceberg compat tests
35+
Seq(CometConf.SCAN_NATIVE_DATAFUSION /*, CometConf.SCAN_NATIVE_ICEBERG_COMPAT*/ ).foreach(
36+
scan =>
37+
super.test(s"$testName - $scan", testTags: _*) {
38+
withSQLConf(
39+
CometConf.COMET_EXEC_ENABLED.key -> "true",
40+
SQLConf.USE_V1_SOURCE_LIST.key -> "parquet",
41+
CometConf.COMET_ENABLED.key -> "true",
42+
CometConf.COMET_EXPLAIN_FALLBACK_ENABLED.key -> "false",
43+
CometConf.COMET_NATIVE_SCAN_IMPL.key -> scan) {
44+
testFun
45+
}
46+
})
4547
}
4648

4749
test("native reader - read simple STRUCT fields") {

0 commit comments

Comments
 (0)