Use analyzed attributes when applying the schema.

marmbrus · marmbrus · commit f96819597b8b · 2014-07-17T17:31:43.000-04:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala
@@ -430,7 +430,7 @@ class SchemaRDD(
    * @group schema
    */
   private def applySchema(rdd: RDD[Row]): SchemaRDD = {
-    new SchemaRDD(sqlContext, SparkLogicalPlan(ExistingRdd(logicalPlan.output, rdd)))
+    new SchemaRDD(sqlContext, SparkLogicalPlan(ExistingRdd(queryExecution.analyzed.output, rdd)))
   }
 
   // =======================================================================

Original file line number	Diff line number	Diff line change
`@@ -430,7 +430,7 @@ class SchemaRDD(`
`430`	`430`	`* @group schema`
`431`	`431`	`*/`
`432`	`432`	`private def applySchema(rdd: RDD[Row]): SchemaRDD = {`
`433`		`- new SchemaRDD(sqlContext, SparkLogicalPlan(ExistingRdd(logicalPlan.output, rdd)))`
	`433`	`+ new SchemaRDD(sqlContext, SparkLogicalPlan(ExistingRdd(queryExecution.analyzed.output, rdd)))`
`434`	`434`	`}`
`435`	`435`
`436`	`436`	`// =======================================================================`