Minor: clean up the code regarding clippy (#8122)

apache · Nov 10, 2023 · fdf3f6c · fdf3f6c
1 parent e305bcf
commit fdf3f6c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/datafusion/core/src/physical_optimizer/limited_distinct_aggregation.rs b/datafusion/core/src/physical_optimizer/limited_distinct_aggregation.rs
@@ -57,7 +57,7 @@ impl LimitedDistinctAggregation {
             aggr.filter_expr().to_vec(),
             aggr.order_by_expr().to_vec(),
             aggr.input().clone(),
-            aggr.input_schema().clone(),
+            aggr.input_schema(),
         )
         .expect("Unable to copy Aggregate!")
         .with_limit(Some(limit));

diff --git a/datafusion/physical-plan/src/limit.rs b/datafusion/physical-plan/src/limit.rs
@@ -229,7 +229,7 @@ impl ExecutionPlan for GlobalLimitExec {
                     let remaining_rows: usize = nr - skip;
                     let mut skip_some_rows_stats = Statistics {
                         num_rows: Precision::Exact(remaining_rows),
-                        column_statistics: col_stats.clone(),
+                        column_statistics: col_stats,
                         total_byte_size: Precision::Absent,
                     };
                     if !input_stats.num_rows.is_exact().unwrap_or(false) {

diff --git a/datafusion/sql/src/statement.rs b/datafusion/sql/src/statement.rs
@@ -1017,7 +1017,7 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
                 expr_to_columns(&filter_expr, &mut using_columns)?;
                 let filter_expr = normalize_col_with_schemas_and_ambiguity_check(
                     filter_expr,
-                    &[&[&scan.schema()]],
+                    &[&[scan.schema()]],
                     &[using_columns],
                 )?;
                 LogicalPlan::Filter(Filter::try_new(filter_expr, Arc::new(scan))?)