risingwave_frontend::handler::create_table

Function gen_create_table_plan_with_source

source 
pub(crate) async fn gen_create_table_plan_with_source(
    handler_args: HandlerArgs,
    explain_options: ExplainOptions,
    table_name: ObjectName,
    column_defs: Vec<ColumnDef>,
    wildcard_idx: Option<usize>,
    constraints: Vec<TableConstraint>,
    format_encode: FormatEncodeOptions,
    source_watermarks: Vec<SourceWatermark>,
    col_id_gen: ColumnIdGenerator,
    append_only: bool,
    on_conflict: Option<OnConflict>,
    with_version_column: Option<String>,
    include_column_options: IncludeOption,
) -> Result<(PlanRef, Option<PbSource>, PbTable), RwError>
Expand description

gen_create_table_plan_with_source generates the plan for creating a table with an external stream source.