@Override
    public InLongMsgBinlogFormatDeserializer createFormatDeserializer(
            Map<String, String> properties) {
        final DescriptorProperties descriptorProperties =
                new DescriptorProperties(true);
        descriptorProperties.putProperties(properties);

        final InLongMsgBinlogValidator validator = new InLongMsgBinlogValidator();
        validator.validate(descriptorProperties);

        RowFormatInfo dataRowFormatInfo = getDataRowFormatInfo(descriptorProperties);
        InLongMsgBinlogFormatDeserializer.Builder builder =
                new InLongMsgBinlogFormatDeserializer.Builder(dataRowFormatInfo);
        builder.configure(descriptorProperties);

        return builder.build();
    }
Table format factory for providing configured instances of InLongMsgBinlog-to-row
serializer and deserializer.
inlong-sort/sort-formats/format-row/format-inlongmsg-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogFormatFactory.java