@Override
            public Object convert(Object dbzObj, Schema schema) throws Exception {
                ConnectSchema connectSchema = (ConnectSchema) schema;
                List<Field> fields = connectSchema.fields();

                Map<String, Object> data = new HashMap<>();
                Struct struct = (Struct) dbzObj;

                for (Field field : fields) {
                    String fieldName = field.name();
                    Object fieldValue = struct.getWithoutDefault(fieldName);
                    Schema fieldSchema = schema.field(fieldName).schema();
                    String schemaName = fieldSchema.name();
                    if (schemaName != null) {
                        // normal type doesn't have schema name
                        // schema names are time schemas
                        fieldValue = getValueWithSchema(fieldValue, schemaName);
                    }
                    data.put(fieldName, fieldValue);
                }

                GenericRowData row = new GenericRowData(1);
                row.setField(0, data);

                return row;
            }
Creates a runtime converter which assuming input object is not null.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java