add_sort_above_with_check

datafusion::physical_optimizer::utils

Function add_sort_above_with_check 

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

This utility function adds a SortExec above an operator according to the given ordering requirements while preserving the original partitioning. If requirement is already satisfied no SortExec is added.