in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java [49:73]
public static String toDorisType(Object value) {
if (value instanceof Integer) {
return DorisType.INT;
} else if (value instanceof Date) {
return DorisType.DATETIME_V2 + "(3)";
} else if (value instanceof BsonTimestamp) {
return DorisType.DATETIME_V2 + "(0)";
} else if (value instanceof Long) {
return DorisType.BIGINT;
} else if (value instanceof Double) {
return checkAndRebuildBigDecimal(new BigDecimal(String.valueOf(value)));
} else if (value instanceof Boolean) {
return DorisType.BOOLEAN;
} else if (value instanceof String) {
return DorisType.STRING;
} else if (value instanceof ObjectId) {
return DorisType.VARCHAR + "(36)";
} else if (value instanceof List) {
return DorisType.ARRAY + "<" + DorisType.STRING + ">";
} else if (value instanceof Decimal128) {
return checkAndRebuildBigDecimal(((Decimal128) value).bigDecimalValue());
} else {
return DorisType.STRING;
}
}