risingwave_frontend::handler::create_sink

Function reparse_table_for_sink

Source 
pub(crate) async fn reparse_table_for_sink(
    session: &Arc<SessionImpl>,
    table_catalog: &Arc<TableCatalog>,
) -> Result<(StreamFragmentGraph, TableCatalog, Option<SourceCatalog>, TableJobType), RwError>