@Override
    public KvSerializationSchema createSerializationSchema(
            Map<String, String> properties) {
        DescriptorProperties descriptorProperties = getValidatedProperties(properties);
        RowFormatInfo rowFormatInfo = getValidatedRowFormatInfo(descriptorProperties);

        return buildSerializationSchema(rowFormatInfo, descriptorProperties);
    }
Table format factory for kv formats.
inlong-sort/sort-formats/format-row/format-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvFormatFactory.java