File tree Expand file tree Collapse file tree 1 file changed +10
-4
lines changed
arrow-select/src/coalesce Expand file tree Collapse file tree 1 file changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -173,8 +173,11 @@ impl<T: ArrowPrimitiveType + Debug> InProgressArray for InProgressPrimitiveArray
173173
174174 // Copy values
175175 // SAFETY: indices are derived from filter predicate
176- self . current
177- . extend ( indices. iter ( ) . map ( |& idx| unsafe { * values. get_unchecked ( idx) } ) ) ;
176+ self . current . extend (
177+ indices
178+ . iter ( )
179+ . map ( |& idx| unsafe { * values. get_unchecked ( idx) } ) ,
180+ ) ;
178181 } else {
179182 self . nulls . append_n_non_nulls ( count) ;
180183 let indices = IndexIterator :: new ( filter. filter_array ( ) , count) ;
@@ -202,8 +205,11 @@ impl<T: ArrowPrimitiveType + Debug> InProgressArray for InProgressPrimitiveArray
202205
203206 // Copy values
204207 // SAFETY: indices are derived from filter predicate
205- self . current
206- . extend ( indices. iter ( ) . map ( |& idx| unsafe { * values. get_unchecked ( idx) } ) ) ;
208+ self . current . extend (
209+ indices
210+ . iter ( )
211+ . map ( |& idx| unsafe { * values. get_unchecked ( idx) } ) ,
212+ ) ;
207213 } else {
208214 self . nulls . append_n_non_nulls ( count) ;
209215 // SAFETY: indices are derived from filter predicate
You can’t perform that action at this time.
0 commit comments