risingwave_frontend::handler::create_source

Function bind_source_pk

source 
pub(crate) async fn bind_source_pk(
    format_encode: &FormatEncodeOptions,
    source_info: &StreamSourceInfo,
    columns: &mut [ColumnCatalog],
    sql_defined_pk_names: Vec<String>,
    with_properties: &WithOptionsSecResolved,
) -> Result<Vec<String>, RwError>
Expand description

Bind column from source. Add key column to table columns if necessary. Return pk_names.