[doris-spark-connector] branch master updated: [feature] support jsonb type (#70)

[diwu]

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new b1415d9  [feature] support jsonb type (#70)
b1415d9 is described below

commit b1415d9737e9407a13300fb982914c0348f14cf2
Author: gnehil <adamlee...@gmail.com>
AuthorDate: Wed Feb 22 22:49:27 2023 +0800

    [feature] support jsonb type (#70)
---
 .../src/main/java/org/apache/doris/spark/serialization/RowBatch.java     | 1 +
 .../src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala          | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java
 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java
index f04cc5d..72c7ac9 100644
--- 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java
+++ 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java
@@ -262,6 +262,7 @@ public class RowBatch {
                     case "CHAR":
                     case "VARCHAR":
                     case "STRING":
+                    case "JSONB":
                         
Preconditions.checkArgument(mt.equals(Types.MinorType.VARCHAR),
                                 typeMismatchMessage(currentType, mt));
                         VarCharVector varCharVector = (VarCharVector) 
curFieldVector;
diff --git 
a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
 
b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
index 2caf162..15ad7a1 100644
--- 
a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
+++ 
b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
@@ -105,6 +105,7 @@ private[spark] object SchemaUtils {
       case "CHAR"            => DataTypes.StringType
       case "LARGEINT"        => DataTypes.StringType
       case "VARCHAR"         => DataTypes.StringType
+      case "JSONB"           => DataTypes.StringType
       case "DECIMALV2"       => DecimalType(precision, scale)
       case "DECIMAL32"       => DecimalType(precision, scale)
       case "DECIMAL64"       => DecimalType(precision, scale)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org