zyhui98 commented on issue #10084:
URL: https://github.com/apache/seatunnel/issues/10084#issuecomment-3552707067
> coverUrl
> public static SeaTunnelDataType<?> deserializeSeaTunnelDataType(
String field, String columnType) {
SqlType sqlType = null;
try {
String compatible = compatibleTypeDeclare(columnType);
sqlType = SqlType.valueOf(compatible.toUpperCase().replace(" ",
""));
} catch (IllegalArgumentException e) {
// nothing
}
if (sqlType == null) {
return parseComplexDataType(field, columnType);
}
switch (sqlType) {
case STRING:
return BasicType.STRING_TYPE;
case BOOLEAN:
return BasicType.BOOLEAN_TYPE;
case TINYINT:
return BasicType.BYTE_TYPE;
case BYTES:
return PrimitiveByteArrayType.INSTANCE;
case SMALLINT:
return BasicType.SHORT_TYPE;
case INT:
return BasicType.INT_TYPE;
case BIGINT:
return BasicType.LONG_TYPE;
case FLOAT:
return BasicType.FLOAT_TYPE;
case DOUBLE:
return BasicType.DOUBLE_TYPE;
case NULL:
return BasicType.VOID_TYPE;
case DATE:
return LocalTimeType.LOCAL_DATE_TYPE;
case TIME:
return LocalTimeType.LOCAL_TIME_TYPE;
case TIMESTAMP:
return LocalTimeType.LOCAL_DATE_TIME_TYPE;
case TIMESTAMP_TZ:
return LocalTimeType.OFFSET_DATE_TIME_TYPE;
case MAP:
return parseMapType(field, columnType);
case BINARY_VECTOR:
return VectorType.VECTOR_BINARY_TYPE;
case FLOAT_VECTOR:
return VectorType.VECTOR_FLOAT_TYPE;
case FLOAT16_VECTOR:
return VectorType.VECTOR_FLOAT16_TYPE;
case BFLOAT16_VECTOR:
return VectorType.VECTOR_BFLOAT16_TYPE;
case SPARSE_FLOAT_VECTOR:
return VectorType.VECTOR_SPARSE_FLOAT_TYPE;
default:
throw CommonError.unsupportedDataType("SeaTunnel",
columnType, field);
}
}
not found
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
