datafusion_physical_optimizer::utils

Function add_sort_above

Source 
pub fn add_sort_above<T: Clone + Default>(
    node: PlanContext<T>,
    sort_requirements: LexRequirement,
    fetch: Option<usize>,
) -> PlanContext<T>
Expand description

This utility function adds a SortExec above an operator according to the given ordering requirements while preserving the original partitioning.