Use scala BigDecimal.

rxin · rxin · commit e9f1de350d13 · 2015-01-15T22:22:18.000-08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala
@@ -78,7 +78,7 @@ trait ScalaReflection {
       convertToScala(k, mapType.keyType) -> convertToScala(v, mapType.valueType)
     }
     case (r: Row, s: StructType) => convertRowToScala(r, s)
-    case (d: Decimal, _: DecimalType) => d.toJavaBigDecimal
+    case (d: Decimal, _: DecimalType) => d.toBigDecimal
     case (other, _) => other
   }
 

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ trait ScalaReflection {`
`78`	`78`	`convertToScala(k, mapType.keyType) -> convertToScala(v, mapType.valueType)`
`79`	`79`	`}`
`80`	`80`	`case (r: Row, s: StructType) => convertRowToScala(r, s)`
`81`		`- case (d: Decimal, _: DecimalType) => d.toJavaBigDecimal`
	`81`	`+ case (d: Decimal, _: DecimalType) => d.toBigDecimal`
`82`	`82`	`case (other, _) => other`
`83`	`83`	`}`
`84`	`84`