risingwave_frontend::handler::create_sink

Function fetch_incoming_sinks

Source 
pub fn fetch_incoming_sinks(
    session: &Arc<SessionImpl>,
    table: &TableCatalog,
) -> Result<Vec<Arc<SinkCatalog>>>