(iotdb-extras) branch master updated: Add support for STRING type (#99)

[critas]

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

CritasWang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb-extras.git


The following commit(s) were added to refs/heads/master by this push:
     new 77bf726  Add support for STRING type (#99)
77bf726 is described below

commit 77bf7268d5ce0ff982d7bd3dd657879d485a5b2b
Author: lixiaobao <lixiaobao0...@gmail.com>
AuthorDate: Mon Oct 19 11:45:53 2026 +0800

    Add support for STRING type (#99)
    
    Co-authored-by: lixiaobao <xiaobao...@litmustech.com>
---
 .../java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java   | 1 +
 .../src/main/java/org/apache/iotdb/flink/IoTDBSink.java              | 5 +++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
 
b/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
index 7749519..25ab96a 100644
--- 
a/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
+++ 
b/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
@@ -72,6 +72,7 @@ public class DefaultIoTSerializationSchema implements 
IoTSerializationSchema<Map
           values.add(Integer.parseInt(valuesStr[i]));
           break;
         case TEXT:
+        case STRING:
           values.add(valuesStr[i]);
           break;
         case FLOAT:
diff --git 
a/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
 
b/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
index f1403bc..5c7172e 100644
--- 
a/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
+++ 
b/connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
@@ -183,8 +183,9 @@ public class IoTDBSink<IN> extends RichSinkFunction<IN> {
       for (int i = 0; i < measurements.size(); i++) {
         String measurement = device + TsFileConstant.PATH_SEPARATOR + 
measurements.get(i);
         IoTDBSinkOptions.TimeseriesOption timeseriesOption = 
timeseriesOptionMap.get(measurement);
-        if (timeseriesOption != null && 
TSDataType.TEXT.equals(timeseriesOption.getDataType())) {
-          // The TEXT data type should be covered by " or '
+        if (timeseriesOption != null && 
(TSDataType.TEXT.equals(timeseriesOption.getDataType()) ||
+                TSDataType.STRING.equals(timeseriesOption.getDataType()))) {
+          // The TEXT/STRING data type should be covered by " or '
           values.set(i, "'" + values.get(i) + "'");
         }
       }