We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7cd2eec commit 0ee4ec8Copy full SHA for 0ee4ec8
1 file changed
spark/src/main/scala/org/apache/comet/planner/gates/V2ScanClassifier.scala
@@ -80,9 +80,7 @@ object V2ScanClassifier extends Logging with ShimSubqueryBroadcast {
80
case scan: CSVScan if COMET_CSV_V2_NATIVE_ENABLED.get(conf) =>
81
classifyCsv(scan, scanExec)
82
83
- case _
84
- if scanExec.scan.getClass.getName ==
85
- "org.apache.iceberg.spark.source.SparkBatchQueryScan" =>
+ case _ if IcebergReflection.isIcebergScanClass(scanExec.scan.getClass.getName) =>
86
classifyIceberg(scanExec, conf)
87
88
case other =>
0 commit comments