risingwave_frontend::handler::create_table

Function gen_table_plan_inner

source 
fn gen_table_plan_inner(
    context: OptimizerContextRef,
    table_name: String,
    columns: Vec<ColumnCatalog>,
    pk_column_ids: Vec<ColumnId>,
    row_id_index: Option<usize>,
    definition: String,
    watermark_descs: Vec<WatermarkDesc>,
    append_only: bool,
    on_conflict: Option<OnConflict>,
    with_version_column: Option<String>,
    version: Option<TableVersion>,
    source_catalog: Option<SourceCatalog>,
    database_id: u32,
    schema_id: u32,
) -> Result<(PlanRef, PbTable), RwError>