private int getJdbcType(String dataType) {
        switch (dataType) {
            case "integer":
                return Types.INTEGER;
            case "timestamp without time zone":
            case "timestamp with time zone":
                return Types.TIMESTAMP;
            case "smallint":
                return Types.SMALLINT;
            case "boolean":
                return Types.BOOLEAN;
            case "text":
                return Types.LONGNVARCHAR;
            case "numeric":
                return Types.NUMERIC;
            case "bigint":
                return Types.BIGINT;
            case "double precision":
                return Types.DOUBLE;
            case "\"char\"":
                return Types.CHAR;
            case "real":
                return Types.REAL;
            case "character varying":
            case "interval":
            case "name":
            case "inet":
            default:
                return Types.VARCHAR;
        }
    }
The metric indicates delay from data generation to leaving the source operator.

<p>Note: the metric is available during the binlog phase. Use 0 to indicate the metric is
unavailable.</p>
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/debezium/internal/DebeziumChangeFetcher.java