Skip to content

Commit 64603b5

Browse files
author
wangzhenhua
committed
wrong position of comments
1 parent f0bbb43 commit 64603b5

File tree

1 file changed

+1
-1
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/estimation

1 file changed

+1
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/estimation/JoinEstimation.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,10 +164,10 @@ object JoinEstimation {
164164
leftKeys: Seq[Expression],
165165
rightKeys: Seq[Expression]): Seq[(AttributeReference, AttributeReference)] = {
166166
leftKeys.zip(rightKeys).flatMap {
167+
case (ExtractAttr(left), ExtractAttr(right)) => Some((left, right))
167168
// Currently we don't deal with equal joins like key1 = key2 + 5.
168169
// Note: join keys from EqualNullSafe also fall into this case (Coalesce), consider to
169170
// support it in the future by using `nullCount` in column stats.
170-
case (ExtractAttr(left), ExtractAttr(right)) => Some((left, right))
171171
case _ => None
172172
}
173173
}

0 commit comments

Comments
 (0)