default Format parsingFormat(
            String serializationType,
            String wrapType,
            String separatorStr,
            String kvSeparatorStr,
            String escapeCharStr,
            Boolean ignoreParseErrors) {
        Format format;
        DataTypeEnum dataType = DataTypeEnum.forType(serializationType);
        switch (dataType) {
            case CSV:
                separatorStr = StringUtil.parseChar(separatorStr);
                CsvFormat csvFormat = new CsvFormat(separatorStr);
                csvFormat.setIgnoreParseErrors(ignoreParseErrors);
                format = csvFormat;
                break;
            case AVRO:
                format = new AvroFormat();
                break;
            case JSON:
                JsonFormat jsonFormat = new JsonFormat();
                jsonFormat.setIgnoreParseErrors(ignoreParseErrors);
                format = jsonFormat;
                break;
            case CANAL:
                format = new CanalJsonFormat();
                break;
            case DEBEZIUM_JSON:
                DebeziumJsonFormat debeziumJsonFormat = new DebeziumJsonFormat();
                debeziumJsonFormat.setIgnoreParseErrors(ignoreParseErrors);
                format = debeziumJsonFormat;
                break;
            case RAW:
                format = new RawFormat();
                break;
            case KV:
                separatorStr = StringUtil.parseChar(separatorStr);
                kvSeparatorStr = StringUtil.parseChar(kvSeparatorStr);
                escapeCharStr = StringUtil.parseChar(escapeCharStr);
                format = new KvFormat(separatorStr, kvSeparatorStr, escapeCharStr, ignoreParseErrors, null, null, null);
                break;
            default:
                throw new IllegalArgumentException(String.format("Unsupported dataType=%s", dataType));
        }
        if (Objects.equals(wrapType, MessageWrapType.INLONG_MSG_V0.getName())) {
            Format innerFormat = format;
            format = new InLongMsgFormat(innerFormat, false);
        }
        return format;
    }
Parse format

@param serializationType data serialization, support: csv, json, canal, avro, etc
@param wrapType whether wrap content with {@link InLongMsgFormat}
@param separatorStr the separator of data content
@param kvSeparatorStr the kv separator
@param escapeCharStr the escape char
@param ignoreParseErrors whether ignore deserialization error data
@return the format for serialized content
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/base/ExtractNodeProvider.java