Skip to content

Commit e9ea8e3

Browse files
committed
feat: prefer native_datafusion scan in auto mode with fallback
In auto scan mode, try native_datafusion scan first and fall back to native_iceberg_compat when native_datafusion is not supported (e.g., when COMET_EXEC_ENABLED is disabled, or DPP is used).
1 parent 5ef5da2 commit e9ea8e3

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

spark/src/main/scala/org/apache/comet/rules/CometScanRule.scala

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,11 @@ case class CometScanRule(session: SparkSession)
167167
}
168168

169169
COMET_NATIVE_SCAN_IMPL.get() match {
170-
case SCAN_AUTO | SCAN_NATIVE_DATAFUSION =>
170+
case SCAN_AUTO =>
171+
nativeDataFusionScan(plan, session, scanExec, r, hadoopConf)
172+
.orElse(nativeIcebergCompatScan(session, scanExec, r, hadoopConf))
173+
.getOrElse(scanExec)
174+
case SCAN_NATIVE_DATAFUSION =>
171175
nativeDataFusionScan(plan, session, scanExec, r, hadoopConf).getOrElse(scanExec)
172176
case SCAN_NATIVE_ICEBERG_COMPAT =>
173177
nativeIcebergCompatScan(session, scanExec, r, hadoopConf).getOrElse(scanExec)

0 commit comments

Comments
 (0)