cargo fmt

Author: geoffreyclaude

datafusion/physical-expr/src/expressions/in_list.rs

@@ -33,8 +33,8 @@ use crate::physical_expr::physical_exprs_bag_equal;
 
 use arrow::array::*;
 use arrow::buffer::{BooleanBuffer, NullBuffer};
-use arrow::compute::kernels::boolean::{not, or_kleene};
 use arrow::compute::SortOptions;
+use arrow::compute::kernels::boolean::{not, or_kleene};
 use arrow::datatypes::*;
 use datafusion_common::{
     DFSchema, Result, ScalarValue, assert_or_internal_err, exec_err,

datafusion/physical-expr/src/expressions/in_list/array_filter.rs

@@ -56,7 +56,8 @@ impl StaticFilter for ArrayStaticFilter {
     /// Checks if values in `v` are contained in the `in_array` using this hash set for lookup.
     fn contains(&self, v: &dyn Array, negated: bool) -> Result<BooleanArray> {
         // Null type comparisons always return null (SQL three-valued logic)
-        if v.data_type() == &DataType::Null || self.in_array.data_type() == &DataType::Null
+        if v.data_type() == &DataType::Null
+            || self.in_array.data_type() == &DataType::Null
         {
             let nulls = NullBuffer::new_null(v.len());
             return Ok(BooleanArray::new(

datafusion/physical-expr/src/expressions/in_list/primitive.rs

@@ -142,13 +142,9 @@ impl<C: BitmapFilterConfig> BitmapFilter<C> {
         nulls: Option<&arrow::buffer::NullBuffer>,
         negated: bool,
     ) -> BooleanArray {
-        build_in_list_result(
-            values.len(),
-            nulls,
-            self.null_count > 0,
-            negated,
-            |i| self.check(unsafe { *values.get_unchecked(i) }),
-        )
+        build_in_list_result(values.len(), nulls, self.null_count > 0, negated, |i| {
+            self.check(unsafe { *values.get_unchecked(i) })
+        })
     }
 }
 
@@ -227,13 +223,9 @@ where
         nulls: Option<&arrow::buffer::NullBuffer>,
         negated: bool,
     ) -> BooleanArray {
-        build_in_list_result(
-            values.len(),
-            nulls,
-            self.null_count > 0,
-            negated,
-            |i| self.check(unsafe { *values.get_unchecked(i) }),
-        )
+        build_in_list_result(values.len(), nulls, self.null_count > 0, negated, |i| {
+            self.check(unsafe { *values.get_unchecked(i) })
+        })
     }
 }
 

datafusion/physical-expr/src/expressions/in_list/strategy.rs

@@ -39,7 +39,8 @@ use super::array_filter::StaticFilter;
 use super::primitive::{PrimitiveFilter, U8Config, U16Config};
 use super::transform::{
     make_bitmap_filter, make_branchless_filter, make_primitive_filter,
-    make_utf8view_branchless_filter, make_utf8view_hash_filter, utf8view_all_short_strings,
+    make_utf8view_branchless_filter, make_utf8view_hash_filter,
+    utf8view_all_short_strings,
 };
 
 // =============================================================================