Use the analyzed plan in DataFrame

Author: marmbrus

sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala

@@ -136,7 +136,7 @@ class DataFrame private[sql](
     })
   }
 
-  @transient protected[sql] val logicalPlan: LogicalPlan = queryExecution.logical match {
+  @transient protected[sql] val logicalPlan: LogicalPlan = queryExecution.analyzed match {
     // For various commands (like DDL) and queries with side effects, we force query optimization to
     // happen right away to let these side effects take place eagerly.
     case _: Command |
@@ -146,7 +146,7 @@ class DataFrame private[sql](
          _: WriteToFile =>
       LogicalRDD(queryExecution.analyzed.output, queryExecution.toRdd)(sqlContext)
     case _ =>
-      queryExecution.logical
+      queryExecution.analyzed
   }
 
   /**