Skip to content

Commit

Permalink
chore: clean useless clone baesd on clippy (apache#7973)
Browse files Browse the repository at this point in the history
  • Loading branch information
Weijun-H authored Oct 29, 2023
1 parent 4a91ce9 commit 9b45967
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ impl PhysicalOptimizerRule for CombinePartialFinalAggregate {
input_agg_exec.filter_expr().to_vec(),
input_agg_exec.order_by_expr().to_vec(),
input_agg_exec.input().clone(),
input_agg_exec.input_schema().clone(),
input_agg_exec.input_schema(),
)
.ok()
.map(Arc::new)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -554,7 +554,7 @@ fn reorder_aggregate_keys(
agg_exec.filter_expr().to_vec(),
agg_exec.order_by_expr().to_vec(),
partial_agg,
agg_exec.input_schema().clone(),
agg_exec.input_schema(),
)?);

// Need to create a new projection to change the expr ordering back
Expand Down
2 changes: 1 addition & 1 deletion datafusion/core/src/physical_optimizer/topk_aggregation.rs
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ impl TopKAggregation {
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));
Expand Down
2 changes: 1 addition & 1 deletion datafusion/physical-expr/src/array_expressions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -811,7 +811,7 @@ fn concat_internal(args: &[ArrayRef]) -> Result<ArrayRef> {
}
}
// Assume all arrays have the same data type
let data_type = list_arrays[0].value_type().clone();
let data_type = list_arrays[0].value_type();
let buffer = valid.finish();

let elements = arrays
Expand Down
2 changes: 1 addition & 1 deletion datafusion/substrait/src/logical_plan/producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -326,7 +326,7 @@ pub fn to_substrait_rel(
left: Some(left),
right: Some(right),
r#type: join_type as i32,
expression: join_expr.clone(),
expression: join_expr,
post_join_filter: None,
advanced_extension: None,
}))),
Expand Down

0 comments on commit 9b45967

Please sign in to comment.