in spark-doris-connector/src/main/java/org/apache/doris/spark/util/ListUtils.java [75:92]
private static String generateSerializedResult(List<Map<Object, Object>> batch, String lineDelimiter)
throws JsonProcessingException {
// when lineDelimiter is null, use strip_outer_array mode, otherwise use json_by_line mode
if (lineDelimiter == null) {
return MAPPER.writeValueAsString(batch);
} else {
StringBuilder builder = new StringBuilder();
for (Map<Object, Object> data : batch) {
builder.append(MAPPER.writeValueAsString(data)).append(lineDelimiter);
}
int lastIdx = builder.lastIndexOf(lineDelimiter);
if (lastIdx != -1) {
return builder.substring(0, lastIdx);
}
return builder.toString();
}
}