risingwave_frontend::handler::create_index

Function assemble_materialize

source 
fn assemble_materialize(
    table_name: String,
    table_catalog: Arc<TableCatalog>,
    context: OptimizerContextRef,
    index_name: String,
    index_columns: &[(ExprImpl, OrderType)],
    include_columns: &[ExprImpl],
    distributed_by_columns_len: usize,
    cardinality: Cardinality,
) -> Result<StreamMaterialize, RwError>
Expand description

Note: distributed by columns must be a prefix of index columns, so we just use distributed_by_columns_len to represent distributed by columns