(auron) branch master updated: remove 'Exec' from nodeName (#1349)

[richox]

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 268e852f remove 'Exec' from nodeName (#1349)
268e852f is described below

commit 268e852fc605ef89cf26f6da0c2706a784bdb454
Author: bkhan <xor...@outlook.com>
AuthorDate: Sat Sep 27 20:20:19 2025 +0800

    remove 'Exec' from nodeName (#1349)
---
 .../spark/sql/execution/auron/plan/NativeProjectExecProvider.scala  | 6 +++---
 .../joins/auron/plan/NativeShuffledHashJoinExecProvider.scala       | 6 +++---
 .../joins/auron/plan/NativeSortMergeJoinExecProvider.scala          | 4 ++--
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeProjectExecProvider.scala
 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeProjectExecProvider.scala
index 0aec8252..51845400 100644
--- 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeProjectExecProvider.scala
+++ 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeProjectExecProvider.scala
@@ -39,7 +39,7 @@ case object NativeProjectExecProvider {
 
       override protected def orderingExpressions = child.outputOrdering
 
-      override def nodeName: String = "NativeProjectExec"
+      override def nodeName: String = "NativeProject"
     }
     NativeProjectExec(projectList, child)
   }
@@ -66,7 +66,7 @@ case object NativeProjectExecProvider {
 
       override protected def orderingExpressions = child.outputOrdering
 
-      override def nodeName: String = "NativeProjectExec"
+      override def nodeName: String = "NativeProject"
     }
     NativeProjectExec(projectList, child)
   }
@@ -80,7 +80,7 @@ case object NativeProjectExecProvider {
       override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
         copy(child = newChildren.head)
 
-      override def nodeName: String = "NativeProjectExec"
+      override def nodeName: String = "NativeProject"
     }
     NativeProjectExec(projectList, child)
   }
diff --git 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeShuffledHashJoinExecProvider.scala
 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeShuffledHashJoinExecProvider.scala
index f907ba4a..f742cb71 100644
--- 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeShuffledHashJoinExecProvider.scala
+++ 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeShuffledHashJoinExecProvider.scala
@@ -75,7 +75,7 @@ case object NativeShuffledHashJoinExecProvider {
         copy(left = newLeft, right = newRight)
 
       override def nodeName: String =
-        "NativeShuffledHashJoinExec" + (if (skewJoin) "(skew=true)" else "")
+        "NativeShuffledHashJoin" + (if (skewJoin) "(skew=true)" else "")
     }
     NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, 
buildSide, isSkewJoin)
   }
@@ -123,7 +123,7 @@ case object NativeShuffledHashJoinExecProvider {
       override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
         copy(left = newChildren(0), right = newChildren(1))
 
-      override def nodeName: String = "NativeShuffledHashJoinExec"
+      override def nodeName: String = "NativeShuffledHashJoin"
     }
     NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, 
buildSide)
   }
@@ -177,7 +177,7 @@ case object NativeShuffledHashJoinExecProvider {
       override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
         copy(left = newChildren(0), right = newChildren(1))
 
-      override def nodeName: String = "NativeShuffledHashJoinExec"
+      override def nodeName: String = "NativeShuffledHashJoin"
     }
     NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, 
buildSide)
   }
diff --git 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeSortMergeJoinExecProvider.scala
 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeSortMergeJoinExecProvider.scala
index 053979ce..067ae071 100644
--- 
a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeSortMergeJoinExecProvider.scala
+++ 
b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeSortMergeJoinExecProvider.scala
@@ -68,7 +68,7 @@ case object NativeSortMergeJoinExecProvider {
         copy(left = newLeft, right = newRight)
 
       override def nodeName: String =
-        "NativeSortMergeJoinExec" + (if (skewJoin) "(skew=true)" else "")
+        "NativeSortMergeJoin" + (if (skewJoin) "(skew=true)" else "")
     }
     NativeSortMergeJoinExec(left, right, leftKeys, rightKeys, joinType, 
skewJoin)
   }
@@ -106,7 +106,7 @@ case object NativeSortMergeJoinExecProvider {
         copy(left = newChildren(0), right = newChildren(1))
 
       override def nodeName: String =
-        "NativeSortMergeJoinExec" + (if (skewJoin) "(skew=true)" else "")
+        "NativeSortMergeJoin" + (if (skewJoin) "(skew=true)" else "")
     }
     NativeSortMergeJoinExec(left, right, leftKeys, rightKeys, joinType, 
skewJoin)
   }