risingwave_frontend::optimizer::plan_node::derive

Function derive_pk

Source 
pub(crate) fn derive_pk(
    input: PlanRef,
    user_order_by: Order,
    columns: &[ColumnCatalog],
) -> (Vec<ColumnOrder>, Vec<usize>)
Expand description

Derive the pk and the stream key for tables and sinks.