default Format parsingSinkMultipleFormat(Boolean multipleEnable, String multipleFormat) {
        Format format = null;
        if (Boolean.TRUE.equals(multipleEnable) && StringUtils.isNotBlank(multipleFormat)) {
            DataTypeEnum dataType = DataTypeEnum.forType(multipleFormat);
            switch (dataType) {
                case CANAL:
                    format = new CanalJsonFormat();
                    break;
                case DEBEZIUM_JSON:
                    format = new DebeziumJsonFormat();
                    break;
                default:
                    throw new IllegalArgumentException(String.format("Unsupported dataType=%s", dataType));
            }
        }
        return format;
    }
Parse format

@param multipleEnable whether to enable multi-write
@param multipleFormat data serialization format
@return the format for serialized content
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/base/LoadNodeProvider.java