risingwave_frontend::handler::alter_table_drop_connector

Function fetch_schema_info

source 
fn fetch_schema_info(
    session: &Arc<SessionImpl>,
    table_name: ObjectName,
) -> Result<(Arc<TableCatalog>, Arc<SourceCatalog>), RwError>