PR feedback

coralogix · Oct 7, 2024 · 369045d · 369045d
1 parent d18c05b
commit 369045d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/datafusion/physical-plan/src/execution_plan.rs b/datafusion/physical-plan/src/execution_plan.rs
@@ -908,7 +908,7 @@ pub fn get_plan_string(plan: &Arc<dyn ExecutionPlan>) -> Vec<String> {
 pub enum CardinalityEffect {
     /// Unknown effect. This is the default
     Unknown,
-    /// The operator is guaranteed to produce exactly one row for 
+    /// The operator is guaranteed to produce exactly one row for
     /// each input row
     Equal,
     /// The operator may produce fewer output rows than it receives input rows

diff --git a/datafusion/physical-plan/src/sorts/sort.rs b/datafusion/physical-plan/src/sorts/sort.rs
@@ -975,7 +975,11 @@ impl ExecutionPlan for SortExec {
     }
 
     fn cardinality_effect(&self) -> CardinalityEffect {
-        CardinalityEffect::Equal
+        if self.fetch.is_none() {
+            CardinalityEffect::Equal
+        } else {
+            CardinalityEffect::LowerEqual
+        }
     }
 }