in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java [52:70]
public String getTypeName(Schema schema) {
if (schema.valueSchema().isOptional()) {
Schema valueSchema = schema.valueSchema();
String type =
Objects.nonNull(valueSchema.name())
? valueSchema.name()
: valueSchema.type().name();
if (recordTypeRegister == null) {
registerNestedArrayType();
}
Type valueType = recordTypeRegister.getTypeRegistry().get(type);
if (valueType == null) {
return DorisType.STRING;
}
String typeName = valueType.getTypeName(schema);
return String.format(ARRAY_TYPE_TEMPLATE, DorisType.ARRAY, typeName);
}
return DorisType.STRING;
}