This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-doris-flink-connector.git
commit 8b0b9c67428c4799e8cf0b19e8565fa72c09c66b
Author: wudi <676366...@qq.com>
AuthorDate: Sat Nov 13 17:10:22 2021 +0800
[Feature] Support Flink and Spark connector support String type (#7075)
Support String type for Flink and Spark connector
---
src/main/java/org/apache/doris/flink/serialization/RowBatch.java | 1 +
src/main/thrift/doris/Types.thrift | 8 +++++++-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
b/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
index 00c699b..3337637 100644
--- a/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
+++ b/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
@@ -251,6 +251,7 @@ public class RowBatch {
case "DATETIME":
case "CHAR":
case "VARCHAR":
+ case "STRING":
Preconditions.checkArgument(mt.equals(Types.MinorType.VARCHAR),
typeMismatchMessage(currentType, mt));
VarCharVector varCharVector = (VarCharVector)
curFieldVector;
diff --git a/src/main/thrift/doris/Types.thrift
b/src/main/thrift/doris/Types.thrift
index 2d902ba..44ce606 100644
--- a/src/main/thrift/doris/Types.thrift
+++ b/src/main/thrift/doris/Types.thrift
@@ -73,7 +73,13 @@ enum TPrimitiveType {
VARCHAR,
HLL,
DECIMALV2,
- TIME
+ TIME,
+ OBJECT,
+ ARRAY,
+ MAP,
+ STRUCT,
+ STRING,
+ ALL
}
enum TTypeNodeType {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
