[doris-flink-connector] branch master updated: add new type jsonb of doris-flink-connector (#104)

[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-flink-connector.git

The following commit(s) were added to refs/heads/master by this push:
     new 14405be  add new type jsonb of doris-flink-connector (#104)
14405be is described below

commit 14405bee255865631e53939f0dae46e306025308
Author: lsy3993 <110876560+lsy3...@users.noreply.github.com>
AuthorDate: Mon Feb 20 19:25:19 2023 +0800

    add new type jsonb of doris-flink-connector (#104)
---
 .../src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java   | 2 ++
 .../src/main/java/org/apache/doris/flink/serialization/RowBatch.java    | 1 +
 2 files changed, 3 insertions(+)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
index 4805704..372b9b2 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
@@ -40,6 +40,7 @@ public class DorisTypeMapper {
     private static final String DORIS_VARCHAR = "VARCHAR";
     private static final String DORIS_STRING = "STRING";
     private static final String DORIS_TEXT = "TEXT";
+    private static final String DORIS_JSONB = "JSONB";
 
     // ------------------------------time-------------------------
     private static final String DORIS_DATE = "DATE";
@@ -85,6 +86,7 @@ public class DorisTypeMapper {
             case DORIS_VARCHAR:
             case DORIS_STRING:
             case DORIS_TEXT:
+            case DORIS_JSONB:
                 return DataTypes.STRING();
             case DORIS_DATE:
             case DORIS_DATEV2:
diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
index 1cd9fdc..8ab9a55 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
@@ -300,6 +300,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;


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