This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new fdf3f6c330 Minor: clean up the code regarding clippy (#8122)
fdf3f6c330 is described below
commit fdf3f6c3304956cd56131d8783d7cb38a2242a9f
Author: Alex Huang <[email protected]>
AuthorDate: Fri Nov 10 22:04:41 2023 +0100
Minor: clean up the code regarding clippy (#8122)
---
datafusion/core/src/physical_optimizer/limited_distinct_aggregation.rs | 2 +-
datafusion/physical-plan/src/limit.rs | 2 +-
datafusion/sql/src/statement.rs | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/datafusion/core/src/physical_optimizer/limited_distinct_aggregation.rs
b/datafusion/core/src/physical_optimizer/limited_distinct_aggregation.rs
index 832a92bb69..8f5dbc2e92 100644
--- 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
index c8427f9bc2..355561c36f 100644
--- 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
index 116624c6f7..ecc77b0442 100644
--- 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))?)