up

Author: yew1eb

native-engine/datafusion-ext-plans/src/limit_exec.rs

@@ -272,7 +272,7 @@ mod test {
     }
 
     #[tokio::test]
-    async fn test_limit_with_skip() -> Result<()> {
+    async fn test_limit_with_offset() -> Result<()> {
         let input = build_table(
             ("a", &vec![0, 1, 2, 3, 4, 5, 6, 7, 8, 9]),
             ("b", &vec![9, 8, 7, 6, 5, 4, 3, 2, 1, 0]),

native-engine/datafusion-ext-plans/src/sort_exec.rs

@@ -133,7 +133,7 @@ pub fn create_default_ascending_sort_exec(
             })
             .collect(),
         None,
-        0
+        0,
     );
     if let Some(execution_plan_metrics) = execution_plan_metrics {
         sort_exec.metrics = execution_plan_metrics;
@@ -190,7 +190,7 @@ impl ExecutionPlan for SortExec {
             children[0].clone(),
             self.exprs.clone(),
             self.limit,
-            self.offset
+            self.offset,
         )))
     }