From 6d932ec1e5d3d54be3f3e4577a103b5d242f7de2 Mon Sep 17 00:00:00 2001
From: Jolan Rensen <Jolan.Rensen@jetbrains.com>
Date: Thu, 22 Sep 2022 12:14:48 +0200
Subject: [PATCH] Added BigInteger support
---
.../src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt | 2 ++
1 file changed, 2 insertions(+)
diff --git a/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt b/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt
index bf76820b..322a38d3 100644
--- a/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt
+++ b/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt
@@ -39,6 +39,7 @@ import scala.Product
import scala.reflect.ClassTag
import java.beans.PropertyDescriptor
import java.math.BigDecimal
+import java.math.BigInteger
import java.sql.Date
import java.sql.Timestamp
import java.time.*
@@ -119,6 +120,7 @@ private val knownDataTypes: Map<KClass<out Any>, DataType> = mapOf(
ByteArray::class to DataTypes.BinaryType,
Decimal::class to DecimalType.SYSTEM_DEFAULT(),
BigDecimal::class to DecimalType.SYSTEM_DEFAULT(),
+ BigInteger::class to DecimalType.SYSTEM_DEFAULT(),
CalendarInterval::class to DataTypes.CalendarIntervalType,
)