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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
