public static Map<String, Integer> getSqlType(@Nullable RowData rowData) {
        if (rowData == null) {
            return null;
        }
        GenericRowData data = (GenericRowData) rowData;
        Map<String, String> mongoDbType = (Map<String, String>) data.getField(1);
        Map<String, Integer> sqlType = new LinkedHashMap<>();
        mongoDbType.forEach((name, value) -> sqlType.put(name, RecordUtils.getSqlType(value)));
        return sqlType;
    }
get sql type from row data, represents the jdbc data type
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/utils/MetaDataUtils.java