@Override
            public DeserializationSchema<RowData> createRuntimeDecoder(
                    DynamicTableSource.Context context,
                    DataType dataType) {
                KvRowDataDeserializationSchema.Builder schemaBuilder =
                        new KvRowDataDeserializationSchema.Builder(
                                TableFormatUtils.deriveRowFormatInfo(dataType),
                                context.createTypeInformation(dataType));
                configureDeserializationSchema(formatOptions, schemaBuilder);
                return schemaBuilder.build();
            }
Table format factory for providing configured instances of KV-to-RowData serializer and
deserializer.
inlong-sort/sort-formats/format-rowdata/format-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvFormatFactory.java