default Object convert(Object dbzObj, Schema schema, TableChange tableSchema) throws Exception {
        return dbzObj;
    }
Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal
data structures.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/DeserializationRuntimeConverter.java