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, Table, Option<PbSource>), RwError>