We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent de7757d commit db4bb48Copy full SHA for db4bb48
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CatalystTypeConverters.scala
@@ -19,6 +19,7 @@ package org.apache.spark.sql.catalyst
19
20
import java.lang.{Iterable => JavaIterable}
21
import java.math.{BigDecimal => JavaBigDecimal}
22
+import java.math.{BigInteger => JavaBigInteger}
23
import java.sql.{Date, Timestamp}
24
import java.util.{Map => JavaMap}
25
import javax.annotation.Nullable
@@ -326,6 +327,7 @@ object CatalystTypeConverters {
326
327
val decimal = scalaValue match {
328
case d: BigDecimal => Decimal(d)
329
case d: JavaBigDecimal => Decimal(d)
330
+ case d: JavaBigInteger => Decimal(d)
331
case d: Decimal => d
332
}
333
if (decimal.changePrecision(dataType.precision, dataType.scale)) {
0 commit comments