This is an automated email from the ASF dual-hosted git repository.

csy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git


The following commit(s) were added to refs/heads/master by this push:
     new 814d4ad9 [AURON #1778] Add 
spark.auron.expression.singleChildFallback.enabled config (#1779)
814d4ad9 is described below

commit 814d4ad9ccde9edf336d4b50631b10f278f84627
Author: yew1eb <[email protected]>
AuthorDate: Tue Jan 27 20:45:17 2026 +0800

    [AURON #1778] Add spark.auron.expression.singleChildFallback.enabled config 
(#1779)
    
    # Which issue does this PR close?
    
    Closes #1778
    
    # Rationale for this change
    
    # What changes are included in this PR?
    
    # Are there any user-facing changes?
    
    # How was this patch tested?
---
 .../main/scala/org/apache/spark/sql/auron/NativeConverters.scala  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
index 7c17cba9..f88c03f2 100644
--- 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
+++ 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeConverters.scala
@@ -102,6 +102,10 @@ object NativeConverters extends Logging {
     AuronConverters.getBooleanConf("spark.auron.datetime.extract.enabled", 
defaultValue = false)
   def castTrimStringEnabled: Boolean =
     AuronConverters.getBooleanConf("spark.auron.cast.trimString", defaultValue 
= true)
+  def singleChildFallbackEnabled: Boolean =
+    AuronConverters.getBooleanConf(
+      "spark.auron.expression.singleChildFallback.enabled",
+      defaultValue = true)
 
   /**
    * Is the data type(scalar or complex) supported by Auron.
@@ -289,6 +293,10 @@ object NativeConverters extends Logging {
       throw new NotImplementedError(s"unsupported expression: (${e.getClass}) 
$e")
     }
 
+    if (!singleChildFallbackEnabled) {
+      return convertExprWithFallback(sparkExpr, isPruningExpr = false, 
fallbackToError)
+    }
+
     try {
       // get number of inconvertible children
       var numInconvertibleChildren = 0

Reply via email to