optimizations_roaring_memebership_check

Author: B Vadlamani

datafusion/physical-plan/src/joins/hash_join/exec.rs

@@ -31,8 +31,6 @@ use crate::filter_pushdown::{
     ChildFilterDescription, ChildPushdownResult, FilterDescription, FilterPushdownPhase,
     FilterPushdownPropagation,
 };
-use crate::joins::{Map, RoaringMapData};
-use roaring::RoaringBitmap;
 use crate::joins::array_map::ArrayMap;
 use crate::joins::hash_join::inlist_builder::build_struct_inlist_values;
 use crate::joins::hash_join::shared_bounds::{
@@ -47,6 +45,7 @@ use crate::joins::utils::{
     swap_join_projection, update_hash,
 };
 use crate::joins::{JoinOn, JoinOnRef, PartitionMode, SharedBitmapBuilder};
+use crate::joins::{Map, RoaringMapData};
 use crate::metrics::{Count, MetricBuilder, MetricCategory};
 use crate::projection::{
     EmbeddedProjection, JoinData, ProjectionExec, try_embed_projection,
@@ -65,6 +64,7 @@ use crate::{
     },
     metrics::{ExecutionPlanMetricsSet, MetricsSet},
 };
+use roaring::RoaringBitmap;
 
 use arrow::array::{Array, ArrayRef, BooleanBufferBuilder, Int32Array, UInt32Array};
 use arrow::compute::concat_batches;

datafusion/physical-plan/src/joins/hash_join/stream.rs

@@ -749,8 +749,7 @@ impl HashJoinStream {
                                 return !is_semi;
                             }
                             let v = arr.value(i) as u32;
-                            let in_set =
-                                v >= min && v <= max && bitmap.contains(v);
+                            let in_set = v >= min && v <= max && bitmap.contains(v);
                             in_set == is_semi
                         });
                         BooleanArray::new(buffer, None)
@@ -762,8 +761,7 @@ impl HashJoinStream {
                                 return !is_semi;
                             }
                             let v = arr.value(i);
-                            let in_set =
-                                v >= min && v <= max && bitmap.contains(v);
+                            let in_set = v >= min && v <= max && bitmap.contains(v);
                             in_set == is_semi
                         });
                         BooleanArray::new(buffer, None)