We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f39f547 commit 29a4f59Copy full SHA for 29a4f59
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -1362,10 +1362,7 @@ class Analyzer(
1362
val rightKeys = joinNames.map(keyName => right.output.find(_.name == keyName).get)
1363
val joinPairs = leftKeys.zip(rightKeys)
1364
1365
- // Add joinPairs to joinConditions
1366
- val newCondition = (condition ++ joinPairs.map {
1367
- case (l, r) => EqualTo(l, r)
1368
- }).reduceOption(And)
+ val newCondition = (condition ++ joinPairs.map(EqualTo.tupled)).reduceOption(And)
1369
1370
// columns not in joinPairs
1371
val lUniqueOutput = left.output.filterNot(att => leftKeys.contains(att))
0 commit comments