public static PostgresSchema newSchema(
            PostgresConnection connection,
            PostgresConnectorConfig config,
            TypeRegistry typeRegistry,
            TopicSelector<TableId> topicSelector,
            PostgresValueConverter valueConverter)
            throws SQLException {
        PostgresSchema schema =
                new PostgresSchema(config, typeRegistry, topicSelector, valueConverter);
        schema.refresh(connection, false);
        return schema;
    }
Create a new PostgresSchema and initialize the content of the schema.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresObjectFactory.java