Skip to main content

handle_create_cdc_table_source

risingwave_frontend::handler::create_source

Function handle_create_cdc_table_source 

Source 
async fn handle_create_cdc_table_source(
    handler_args: HandlerArgs,
    stmt: CreateSourceStatement,
) -> Result<RwPgResponse>