datafusion_physical_optimizer::utils

Function add_sort_above_with_check

Source 
pub fn add_sort_above_with_check<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. If requirement is already satisfied no SortExec is added.