Skip to content
Permalink
Browse files
[Feature] Support Flink and Spark connector support String type (#7075)
Support String type for Flink and Spark connector
  • Loading branch information
JNSimba committed Nov 13, 2021
1 parent 86d3e56 commit 8b0b9c67428c4799e8cf0b19e8565fa72c09c66b
Showing 2 changed files with 8 additions and 1 deletion.
@@ -251,6 +251,7 @@ public void convertArrowToRowBatch() throws DorisException {
case "DATETIME":
case "CHAR":
case "VARCHAR":
case "STRING":
Preconditions.checkArgument(mt.equals(Types.MinorType.VARCHAR),
typeMismatchMessage(currentType, mt));
VarCharVector varCharVector = (VarCharVector) curFieldVector;
@@ -73,7 +73,13 @@ enum TPrimitiveType {
VARCHAR,
HLL,
DECIMALV2,
TIME
TIME,
OBJECT,
ARRAY,
MAP,
STRUCT,
STRING,
ALL
}

enum TTypeNodeType {

0 comments on commit 8b0b9c6

Please sign in to comment.