perf: Don't collect all LHS arrays in gather (#20441)

pola-rs · Dec 24, 2024 · d27f7b2 · d27f7b2
1 parent 0ed4b4c
commit d27f7b2
Showing 1 changed file with 11 additions and 14 deletions.
diff --git a/crates/polars-ops/src/chunked_array/gather/chunked.rs b/crates/polars-ops/src/chunked_array/gather/chunked.rs
@@ -321,31 +321,30 @@ where
     ) -> Self {
         let arrow_dtype = self.dtype().to_arrow(CompatLevel::newest());
 
-        let mut out = if let Some(iter) = self.downcast_slices() {
-            let targets = iter.collect::<Vec<_>>();
+        let mut out = if !self.has_nulls() {
             let iter = by.iter().map(|chunk_id| {
                 debug_assert!(
                     !chunk_id.is_null(),
                     "null chunks should not hit this branch"
                 );
                 let (chunk_idx, array_idx) = chunk_id.extract();
-                let vals = targets.get_unchecked(chunk_idx as usize);
-                vals.get_unchecked(array_idx as usize).clone()
+                let arr = self.downcast_get_unchecked(chunk_idx as usize);
+                arr.value_unchecked(array_idx as usize).clone()
             });
 
             let arr = iter.collect_arr_trusted_with_dtype(arrow_dtype);
             ChunkedArray::with_chunk(self.name().clone(), arr)
         } else {
-            let targets = self.downcast_iter().collect::<Vec<_>>();
             let iter = by.iter().map(|chunk_id| {
                 debug_assert!(
                     !chunk_id.is_null(),
                     "null chunks should not hit this branch"
                 );
                 let (chunk_idx, array_idx) = chunk_id.extract();
-                let vals = targets.get_unchecked(chunk_idx as usize);
-                vals.get_unchecked(array_idx as usize)
+                let arr = self.downcast_get_unchecked(chunk_idx as usize);
+                arr.get_unchecked(array_idx as usize)
             });
+
             let arr = iter.collect_arr_trusted_with_dtype(arrow_dtype);
             ChunkedArray::with_chunk(self.name().clone(), arr)
         };
@@ -358,33 +357,31 @@ where
     unsafe fn take_opt_chunked_unchecked<const B: u64>(&self, by: &[ChunkId<B>]) -> Self {
         let arrow_dtype = self.dtype().to_arrow(CompatLevel::newest());
 
-        if let Some(iter) = self.downcast_slices() {
-            let targets = iter.collect::<Vec<_>>();
+        if !self.has_nulls() {
             let arr = by
                 .iter()
                 .map(|chunk_id| {
                     if chunk_id.is_null() {
                         None
                     } else {
                         let (chunk_idx, array_idx) = chunk_id.extract();
-                        let vals = *targets.get_unchecked(chunk_idx as usize);
-                        Some(vals.get_unchecked(array_idx as usize).clone())
+                        let arr = self.downcast_get_unchecked(chunk_idx as usize);
+                        Some(arr.value_unchecked(array_idx as usize).clone())
                     }
                 })
                 .collect_arr_trusted_with_dtype(arrow_dtype);
 
             ChunkedArray::with_chunk(self.name().clone(), arr)
         } else {
-            let targets = self.downcast_iter().collect::<Vec<_>>();
             let arr = by
                 .iter()
                 .map(|chunk_id| {
                     if chunk_id.is_null() {
                         None
                     } else {
                         let (chunk_idx, array_idx) = chunk_id.extract();
-                        let vals = *targets.get_unchecked(chunk_idx as usize);
-                        vals.get_unchecked(array_idx as usize)
+                        let arr = self.downcast_get_unchecked(chunk_idx as usize);
+                        arr.get_unchecked(array_idx as usize)
                     }
                 })
                 .collect_arr_trusted_with_dtype(arrow_dtype);