aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorLiang-Chi Hsieh <viirya@gmail.com>2015-06-13 22:42:28 -0700
committerReynold Xin <rxin@databricks.com>2015-06-13 22:42:28 -0700
commitcb7ada1196b5e13f0d4bb1988dc707a72003b8bc (patch)
tree507c2e2f2b219c8d536d4385a585b297b5e463df /sql
parent35d1267cf8e918032c92a206b22bb301bf0c806e (diff)
downloadspark-cb7ada1196b5e13f0d4bb1988dc707a72003b8bc.tar.gz
spark-cb7ada1196b5e13f0d4bb1988dc707a72003b8bc.tar.bz2
spark-cb7ada1196b5e13f0d4bb1988dc707a72003b8bc.zip
[SPARK-8342][SQL] Fix Decimal setOrNull
JIRA: https://issues.apache.org/jira/browse/SPARK-8342 Author: Liang-Chi Hsieh <viirya@gmail.com> Closes #6797 from viirya/fix_decimal and squashes the following commits: 8a447b1 [Liang-Chi Hsieh] Add unit test. d67a5ea [Liang-Chi Hsieh] Merge remote-tracking branch 'upstream/master' into fix_decimal ab6d8af [Liang-Chi Hsieh] Fix setOrNull.
Diffstat (limited to 'sql')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala2
-rw-r--r--sql/catalyst/src/test/scala/org/apache/spark/sql/types/decimal/DecimalSuite.scala6
2 files changed, 7 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala
index eb3c58c37f..a85af9e04a 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala
@@ -86,7 +86,7 @@ final class Decimal extends Ordered[Decimal] with Serializable {
if (precision < 19) {
return null // Requested precision is too low to represent this value
}
- this.decimalVal = BigDecimal(longVal)
+ this.decimalVal = BigDecimal(unscaled)
this.longVal = 0L
} else {
val p = POW_10(math.min(precision, MAX_LONG_DIGITS))
diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/types/decimal/DecimalSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/types/decimal/DecimalSuite.scala
index 28b373e258..4c0365cf1b 100644
--- a/sql/catalyst/src/test/scala/org/apache/spark/sql/types/decimal/DecimalSuite.scala
+++ b/sql/catalyst/src/test/scala/org/apache/spark/sql/types/decimal/DecimalSuite.scala
@@ -156,4 +156,10 @@ class DecimalSuite extends SparkFunSuite with PrivateMethodTester {
assert(Decimal(-100) % Decimal(3) === Decimal(-1))
assert(Decimal(100) % Decimal(0) === null)
}
+
+ test("set/setOrNull") {
+ assert(new Decimal().set(10L, 10, 0).toUnscaledLong === 10L)
+ assert(new Decimal().set(100L, 10, 0).toUnscaledLong === 100L)
+ assert(Decimal(Long.MaxValue, 100, 0).toUnscaledLong === Long.MaxValue)
+ }
}