File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -336,13 +336,12 @@ object QueryPlan extends PredicateHelper {
336
336
* `Attribute`, and replace it with `BoundReference` will cause error.
337
337
*/
338
338
def normalizeExpressions [T <: Expression ](e : T , input : AttributeSeq ): T = {
339
- type T2 = QueryPlan [_]
340
339
e.transformUp {
341
- case s : PlanExpression [T2 @ unchecked] =>
340
+ case s : PlanExpression [QueryPlan [_] @ unchecked] =>
342
341
// Normalize the outer references in the subquery plan.
343
342
val normalizedPlan = s.plan.transformAllExpressions {
344
343
case OuterReference (r) => OuterReference (QueryPlan .normalizeExpressions(r, input))
345
- }.canonicalized. asInstanceOf [ T2 ]
344
+ }.canonicalized
346
345
s.withNewPlan(normalizedPlan)
347
346
348
347
case ar : AttributeReference =>
You can’t perform that action at this time.
0 commit comments