Add comment for SMJ/SHJ changed to BHJ

c21 · c21 · commit ff52751b5100 · 2020-08-21T16:35:34.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/EliminateJoinToEmptyRelation.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/EliminateJoinToEmptyRelation.scala
@@ -30,6 +30,9 @@ import org.apache.spark.sql.execution.joins.{EmptyHashedRelation, EmptyHashedRel
  *
  * 2. Join is inner or left semi join, and broadcasted [[HashedRelation]]
  *    is [[EmptyHashedRelation]].
+ *    This applies to all Joins (sort merge join, shuffled hash join, and broadcast hash join),
+ *    because sort merge join and shuffled hash join will be changed to broadcast hash join with AQE
+ *    at the first place.
  */
 object EliminateJoinToEmptyRelation extends Rule[LogicalPlan] {
 

Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,9 @@ import org.apache.spark.sql.execution.joins.{EmptyHashedRelation, EmptyHashedRel`
`30`	`30`	`*`
`31`	`31`	`* 2. Join is inner or left semi join, and broadcasted [[HashedRelation]]`
`32`	`32`	`* is [[EmptyHashedRelation]].`
	`33`	`+ * This applies to all Joins (sort merge join, shuffled hash join, and broadcast hash join),`
	`34`	`+ * because sort merge join and shuffled hash join will be changed to broadcast hash join with AQE`
	`35`	`+ * at the first place.`
`33`	`36`	`*/`
`34`	`37`	`object EliminateJoinToEmptyRelation extends Rule[LogicalPlan] {`
`35`	`38`