We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0b8cd70 commit 795920aCopy full SHA for 795920a
sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -467,8 +467,8 @@ class DataFrame private[sql](
467
// By the time we get here, since we have already run analysis, all attributes should've been
468
// resolved and become AttributeReference.
469
val cond = plan.condition.map { _.transform {
470
- case EqualTo(a: AttributeReference, b: AttributeReference) if a.sameRef(b) =>
471
- EqualTo(plan.left.resolve(a.name), plan.right.resolve(b.name))
+ case expressions.EqualTo(a: AttributeReference, b: AttributeReference) if a.sameRef(b) =>
+ expressions.EqualTo(plan.left.resolve(a.name), plan.right.resolve(b.name))
472
}}
473
plan.copy(condition = cond)
474
}
0 commit comments