Implement maintains_input_order for AggregateExec

apache · Dec 24, 2024 · 49ab893 · 49ab893
1 parent b4b267a
commit 49ab893
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/datafusion/physical-plan/src/aggregates/mod.rs b/datafusion/physical-plan/src/aggregates/mod.rs
@@ -792,6 +792,11 @@ impl ExecutionPlan for AggregateExec {
         vec![self.required_input_ordering.clone()]
     }
 
+    fn maintains_input_order(&self) -> Vec<bool> {
+        // See: InputOrderMode documentation for aggregations
+        vec![self.input_order_mode != InputOrderMode::Linear]
+    }
+
     fn children(&self) -> Vec<&Arc<dyn ExecutionPlan>> {
         vec![&self.input]
     }