@SuppressWarnings("rawtypes")
    public static AbstractDynamicSchemaFormat getFormat(String identifier, Map<String, String> properties) {
        Preconditions.checkNotNull(identifier, "The identifier is null");
        return Optional.ofNullable(SUPPORT_FORMATS.get(identifier))
                .orElseThrow(
                        () -> new UnsupportedOperationException("Unsupport dynamic schema format for:" + identifier))
                .apply(properties);
    }
Get format from the format name, it only supports [canal-json|debezium-json] for now

@param identifier The identifier of this format
@return The dynamic format
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/format/DynamicSchemaFormatFactory.java