risingwave_frontend::handler::create_sink

Function fetch_incoming_sinks

Source 
pub fn fetch_incoming_sinks(
    session: &Arc<SessionImpl>,
    incoming_sink_ids: &HashSet<u32>,
) -> Result<Vec<Arc<SinkCatalog>>, RwError>