in src/columnar_storage/src/storage.rs [227:242]
fn build_sort_exprs(&self, df_schema: &DFSchema, sort_seq: bool) -> Result<LexOrdering> {
let mut sort_exprs = (0..self.schema.num_primary_keys)
.map(|i| {
ident(self.schema().field(i).name())
.sort(true /* asc */, true /* nulls_first */)
})
.collect::<Vec<_>>();
if sort_seq {
sort_exprs.push(ident(SEQ_COLUMN_NAME).sort(true, true));
}
let sort_exprs =
create_physical_sort_exprs(&sort_exprs, df_schema, &ExecutionProps::default())
.context("create physical sort exprs")?;
Ok(sort_exprs)
}