This is an automated email from the ASF dual-hosted git repository.
mingliang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 802dfa690d [CORE] Add buildSide info for
BroadcastNestedLoopJoinExecTransformer simpleStringWithNodeId (#7948)
802dfa690d is described below
commit 802dfa690dc0eff18cfc6fe0f66e36e968f11436
Author: Mingliang Zhu <[email protected]>
AuthorDate: Fri Nov 15 17:19:45 2024 +0800
[CORE] Add buildSide info for BroadcastNestedLoopJoinExecTransformer
simpleStringWithNodeId (#7948)
---
.../gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala
b/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala
index ae407b3b3e..1e0c3d5a7e 100644
---
a/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala
+++
b/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala
@@ -27,7 +27,7 @@ import org.apache.spark.sql.catalyst.expressions.{Attribute,
Expression}
import org.apache.spark.sql.catalyst.optimizer.{BuildLeft, BuildRight,
BuildSide}
import org.apache.spark.sql.catalyst.plans.{FullOuter, InnerLike, JoinType,
LeftExistence, LeftOuter, RightOuter}
import org.apache.spark.sql.catalyst.plans.physical.Partitioning
-import org.apache.spark.sql.execution.SparkPlan
+import org.apache.spark.sql.execution.{ExplainUtils, SparkPlan}
import org.apache.spark.sql.execution.joins.BaseJoinExec
import org.apache.spark.sql.execution.metric.SQLMetric
@@ -45,6 +45,11 @@ abstract class BroadcastNestedLoopJoinExecTransformer(
def joinBuildSide: BuildSide = buildSide
+ override def simpleStringWithNodeId(): String = {
+ val opId = ExplainUtils.getOpId(this)
+ s"$nodeName $joinType $joinBuildSide ($opId)".trim
+ }
+
override def leftKeys: Seq[Expression] = Nil
override def rightKeys: Seq[Expression] = Nil
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
