diff --git a/datafusion/src/physical_plan/hash_aggregate.rs b/datafusion/src/physical_plan/hash_aggregate.rs index f1611ebd7a775..ca1df52987020 100644 --- a/datafusion/src/physical_plan/hash_aggregate.rs +++ b/datafusion/src/physical_plan/hash_aggregate.rs @@ -508,7 +508,7 @@ fn dictionary_create_key_for_col( )) })?; - create_key_for_col(&dict_col.values(), values_index, vec) + create_key_for_col(dict_col.values(), values_index, vec) } /// Appends a sequence of [u8] bytes for the value in `col[row]` to @@ -1091,7 +1091,7 @@ fn dictionary_create_group_by_value( )) })?; - create_group_by_value(&dict_col.values(), values_index) + create_group_by_value(dict_col.values(), values_index) } /// Extract the value in `col[row]` as a GroupByScalar diff --git a/datafusion/src/physical_plan/mod.rs b/datafusion/src/physical_plan/mod.rs index fba45a6d5479c..713956f00a9e3 100644 --- a/datafusion/src/physical_plan/mod.rs +++ b/datafusion/src/physical_plan/mod.rs @@ -477,7 +477,7 @@ pub trait WindowExpr: Send + Sync + Debug { fn evaluate_args(&self, batch: &RecordBatch) -> Result> { self.expressions() .iter() - .map(|e| e.evaluate(&batch)) + .map(|e| e.evaluate(batch)) .map(|r| r.map(|v| v.into_array(batch.num_rows()))) .collect() } diff --git a/datafusion/src/scalar.rs b/datafusion/src/scalar.rs index 933bb8cebcb1c..7f9695f09780d 100644 --- a/datafusion/src/scalar.rs +++ b/datafusion/src/scalar.rs @@ -778,7 +778,7 @@ impl ScalarValue { keys_col.data_type() )) })?; - Self::try_from_array(&dict_array.values(), values_index) + Self::try_from_array(dict_array.values(), values_index) } }