Skip to main content

sanity_check_for_table_on_cdc_source

risingwave_frontend::handler::cdc

Function sanity_check_for_table_on_cdc_source 

Source 
pub(crate) fn sanity_check_for_table_on_cdc_source(
    append_only: bool,
    column_defs: &Vec<ColumnDef>,
    wildcard_idx: &Option<usize>,
    constraints: &Vec<TableConstraint>,
    source_watermarks: &Vec<SourceWatermark>,
) -> Result<()>