Cast to double to fix SPARK-7687

JoshRosen · JoshRosen · commit f2065809cace · 2015-05-18T13:49:32.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -1063,7 +1063,7 @@ class DataFrame private[sql](
 
     val ret: Seq[Row] = if (outputCols.nonEmpty) {
       val aggExprs = statistics.flatMap { case (_, colToAgg) =>
-        outputCols.map(c => Column(colToAgg(Column(c).expr)).as(c))
+        outputCols.map(c => Column(Cast(colToAgg(Column(c).expr), DoubleType)).as(c))
       }
 
       val row = agg(aggExprs.head, aggExprs.tail: _*).head().toSeq

Original file line number	Diff line number	Diff line change
`@@ -1063,7 +1063,7 @@ class DataFrame private[sql](`
`1063`	`1063`
`1064`	`1064`	`val ret: Seq[Row] = if (outputCols.nonEmpty) {`
`1065`	`1065`	`val aggExprs = statistics.flatMap { case (_, colToAgg) =>`
`1066`		`- outputCols.map(c => Column(colToAgg(Column(c).expr)).as(c))`
	`1066`	`+ outputCols.map(c => Column(Cast(colToAgg(Column(c).expr), DoubleType)).as(c))`
`1067`	`1067`	`}`
`1068`	`1068`
`1069`	`1069`	`val row = agg(aggExprs.head, aggExprs.tail: _*).head().toSeq`