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.
pub(crate) fn derive_pk(
input: PlanRef,
user_order_by: Order,
columns: &[ColumnCatalog],
) -> (Vec<ColumnOrder>, Vec<usize>)
Derive the pk and the stream key for tables and sinks.