You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@auron.apache.org by ri...@apache.org on 2025/12/01 06:32:14 UTC
(auron) branch master updated: [AURON #1665] Override verboseStringWithOperatorId in NativeFilterBase (#1667)
This is an automated email from the ASF dual-hosted git repository.
richox 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 fb87a929 [AURON #1665] Override verboseStringWithOperatorId in NativeFilterBase (#1667)
fb87a929 is described below
commit fb87a929aea2b96d97c5e55837dd93a65d991f72
Author: Thomas <ye...@gmail.com>
AuthorDate: Mon Dec 1 14:32:09 2025 +0800
[AURON #1665] Override verboseStringWithOperatorId in NativeFilterBase (#1667)
---
.../spark/sql/execution/auron/plan/NativeFilterBase.scala | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFilterBase.scala b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFilterBase.scala
index 56d46c46..56b21e9a 100644
--- a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFilterBase.scala
+++ b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFilterBase.scala
@@ -32,9 +32,7 @@ import org.apache.spark.sql.catalyst.expressions.Expression
import org.apache.spark.sql.catalyst.expressions.IsNotNull
import org.apache.spark.sql.catalyst.expressions.SortOrder
import org.apache.spark.sql.catalyst.plans.physical.Partitioning
-import org.apache.spark.sql.execution.FilterExec
-import org.apache.spark.sql.execution.SparkPlan
-import org.apache.spark.sql.execution.UnaryExecNode
+import org.apache.spark.sql.execution.{ExplainUtils, FilterExec, SparkPlan, UnaryExecNode}
import org.apache.spark.sql.execution.metric.SQLMetric
import org.apache.auron.metric.SparkMetricNode
@@ -111,4 +109,12 @@ abstract class NativeFilterBase(condition: Expression, override val child: Spark
},
friendlyName = "NativeRDD.Filter")
}
+
+ override def verboseStringWithOperatorId(): String = {
+ s"""
+ |$formattedNodeName
+ |${ExplainUtils.generateFieldString("Input", child.output)}
+ |Condition : ${condition}
+ |""".stripMargin
+ }
}