fix clippy

apache · Jun 13, 2021 · 2650680 · 2650680
1 parent 7fbe3f0
commit 2650680
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git 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<K: ArrowDictionaryKeyType>(
         ))
     })?;
 
-    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<K: ArrowDictionaryKeyType>(
         ))
     })?;
 
-    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
@@ -477,7 +477,7 @@ pub trait WindowExpr: Send + Sync + Debug {
     fn evaluate_args(&self, batch: &RecordBatch) -> Result<Vec<ArrayRef>> {
         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
@@ -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)
     }
 }