datafusion_physical_optimizer::enforce_distribution

Function reorder_aggregate_keys

Source 
pub fn reorder_aggregate_keys(
    agg_node: PlanWithKeyRequirements,
    agg_exec: &AggregateExec,
) -> Result<PlanWithKeyRequirements>