File tree Expand file tree Collapse file tree
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1091,7 +1091,7 @@ class Analyzer(
10911091 }
10921092
10931093 /*
1094- * Note that it's possible for conflictPlans to be empty while it implies that there
1094+ * Note that it's possible ` conflictPlans` can be empty which implies that there
10951095 * is a logical plan node that produces new references that this rule cannot handle.
10961096 * When that is the case, there must be another rule that resolves these conflicts.
10971097 * Otherwise, the analysis will fail.
@@ -1103,9 +1103,9 @@ class Analyzer(
11031103 case (oldRelation, newRelation) => oldRelation.output.zip(newRelation.output)})
11041104 val conflictPlanMap = conflictPlans.toMap
11051105 // transformDown so that we can replace all the old Relations in one turn due to
1106- // the reason that conflictPlans are also collected in pre-order.
1106+ // the reason that ` conflictPlans` are also collected in pre-order.
11071107 right transformDown {
1108- case r if conflictPlanMap.contains(r) => conflictPlanMap( r)
1108+ case r => conflictPlanMap.getOrElse(r, r)
11091109 } transformUp {
11101110 case other => other transformExpressions {
11111111 case a : Attribute =>
You can’t perform that action at this time.
0 commit comments