Skip to content

Commit

Permalink
[CORE] Add buildSide info for BroadcastNestedLoopJoinExecTransformer …
Browse files Browse the repository at this point in the history
…simpleStringWithNodeId (#7948)
  • Loading branch information
zml1206 authored Nov 15, 2024
1 parent c7548aa commit 802dfa6
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand All @@ -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

Expand Down

0 comments on commit 802dfa6

Please sign in to comment.