risingwave_frontend::handler::create_table

Function bind_cdc_table_schema

source 
fn bind_cdc_table_schema(
    column_defs: &Vec<ColumnDef>,
    constraints: &Vec<TableConstraint>,
    new_version_columns: Option<Vec<ColumnCatalog>>,
) -> Result<(Vec<ColumnCatalog>, Vec<String>), RwError>
Expand description

Derive schema for cdc table when create a new Table or alter an existing Table