in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java [424:441]
private String escapeString(String hexData) {
if (hexData.startsWith("\\x") || hexData.startsWith("\\X")) {
try {
hexData = hexData.substring(2);
StringBuilder stringBuilder = new StringBuilder();
for (int i = 0; i < hexData.length(); i += 2) {
String hexByte = hexData.substring(i, i + 2);
int decimal = Integer.parseInt(hexByte, 16);
char character = (char) decimal;
stringBuilder.append(character);
}
return stringBuilder.toString();
} catch (Exception e) {
throw new RuntimeException("escape column_separator or line_delimiter error.{}", e);
}
}
return hexData;
}