Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer committed Sep 11, 2024
1 parent 0309f02 commit 52d7da9
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,10 +28,8 @@ import org.apache.spark.sql.execution.joins.{ShuffledHashJoinExec, SortMergeJoin
/** If force ShuffledHashJoin, convert [[SortMergeJoinExec]] to [[ShuffledHashJoinExec]]. */
object RewriteJoin extends RewriteSingleNode with JoinSelectionHelper {
private def getSmjBuildSide(join: SortMergeJoinExec): Option[BuildSide] = {
val leftBuildable =
BackendsApiManager.getSettings.supportHashBuildJoinTypeOnLeft(join.joinType)
val rightBuildable =
BackendsApiManager.getSettings.supportHashBuildJoinTypeOnRight(join.joinType)
val leftBuildable = canBuildShuffledHashJoinLeft(join.joinType)
val rightBuildable = canBuildShuffledHashJoinRight(join.joinType)
if (!leftBuildable && !rightBuildable) {
return None
}
Expand Down

0 comments on commit 52d7da9

Please sign in to comment.