in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java [604:633]
public static String completeMilliseconds(String stringValue) {
if (stringValue.length() == DATETIMEV2_PATTERN.length()) {
return stringValue;
}
if (stringValue.length() < DATETIME_PATTERN.length()) {
return stringValue;
}
if (stringValue.length() == DATETIME_PATTERN.length()) {
stringValue += ".";
}
int s = DATETIMEV2_PATTERN.length() - stringValue.length();
switch (s) {
case 1:
return stringValue + "0";
case 2:
return stringValue + "00";
case 3:
return stringValue + "000";
case 4:
return stringValue + "0000";
case 5:
return stringValue + "00000";
case 6:
return stringValue + "000000";
default:
return stringValue;
}
}