Skip to content

Commit bf69b61

Browse files
XorSumTartarus0zm
authored andcommitted
remove 'Exec' from nodeName (apache#1349)
1 parent a4ea8df commit bf69b61

3 files changed

Lines changed: 8 additions & 8 deletions

File tree

spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeProjectExecProvider.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ case object NativeProjectExecProvider {
3939

4040
override protected def orderingExpressions = child.outputOrdering
4141

42-
override def nodeName: String = "NativeProjectExec"
42+
override def nodeName: String = "NativeProject"
4343
}
4444
NativeProjectExec(projectList, child)
4545
}
@@ -66,7 +66,7 @@ case object NativeProjectExecProvider {
6666

6767
override protected def orderingExpressions = child.outputOrdering
6868

69-
override def nodeName: String = "NativeProjectExec"
69+
override def nodeName: String = "NativeProject"
7070
}
7171
NativeProjectExec(projectList, child)
7272
}
@@ -80,7 +80,7 @@ case object NativeProjectExecProvider {
8080
override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
8181
copy(child = newChildren.head)
8282

83-
override def nodeName: String = "NativeProjectExec"
83+
override def nodeName: String = "NativeProject"
8484
}
8585
NativeProjectExec(projectList, child)
8686
}

spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeShuffledHashJoinExecProvider.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ case object NativeShuffledHashJoinExecProvider {
7575
copy(left = newLeft, right = newRight)
7676

7777
override def nodeName: String =
78-
"NativeShuffledHashJoinExec" + (if (skewJoin) "(skew=true)" else "")
78+
"NativeShuffledHashJoin" + (if (skewJoin) "(skew=true)" else "")
7979
}
8080
NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, buildSide, isSkewJoin)
8181
}
@@ -123,7 +123,7 @@ case object NativeShuffledHashJoinExecProvider {
123123
override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
124124
copy(left = newChildren(0), right = newChildren(1))
125125

126-
override def nodeName: String = "NativeShuffledHashJoinExec"
126+
override def nodeName: String = "NativeShuffledHashJoin"
127127
}
128128
NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, buildSide)
129129
}
@@ -177,7 +177,7 @@ case object NativeShuffledHashJoinExecProvider {
177177
override def withNewChildren(newChildren: Seq[SparkPlan]): SparkPlan =
178178
copy(left = newChildren(0), right = newChildren(1))
179179

180-
override def nodeName: String = "NativeShuffledHashJoinExec"
180+
override def nodeName: String = "NativeShuffledHashJoin"
181181
}
182182
NativeShuffledHashJoinExec(left, right, leftKeys, rightKeys, joinType, buildSide)
183183
}

spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/execution/joins/auron/plan/NativeSortMergeJoinExecProvider.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ case object NativeSortMergeJoinExecProvider {
6868
copy(left = newLeft, right = newRight)
6969

7070
override def nodeName: String =
71-
"NativeSortMergeJoinExec" + (if (skewJoin) "(skew=true)" else "")
71+
"NativeSortMergeJoin" + (if (skewJoin) "(skew=true)" else "")
7272
}
7373
NativeSortMergeJoinExec(left, right, leftKeys, rightKeys, joinType, skewJoin)
7474
}
@@ -106,7 +106,7 @@ case object NativeSortMergeJoinExecProvider {
106106
copy(left = newChildren(0), right = newChildren(1))
107107

108108
override def nodeName: String =
109-
"NativeSortMergeJoinExec" + (if (skewJoin) "(skew=true)" else "")
109+
"NativeSortMergeJoin" + (if (skewJoin) "(skew=true)" else "")
110110
}
111111
NativeSortMergeJoinExec(left, right, leftKeys, rightKeys, joinType, skewJoin)
112112
}

0 commit comments

Comments
 (0)