File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
datafusion/physical-expr/src Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -192,14 +192,13 @@ impl AsyncFuncExpr {
192192 ) ;
193193 }
194194
195- let data_vec = ColumnarValue :: values_to_arrays ( & result_batches) ?
195+ let datas = ColumnarValue :: values_to_arrays ( & result_batches) ?
196196 . iter ( )
197197 . map ( |b| b. to_data ( ) )
198198 . collect :: < Vec < _ > > ( ) ;
199- let total_len = data_vec. iter ( ) . map ( |d| d. len ( ) ) . sum ( ) ;
200- let mut mutable =
201- MutableArrayData :: new ( data_vec. iter ( ) . collect ( ) , false , total_len) ;
202- data_vec. iter ( ) . enumerate ( ) . for_each ( |( i, data) | {
199+ let total_len = datas. iter ( ) . map ( |d| d. len ( ) ) . sum ( ) ;
200+ let mut mutable = MutableArrayData :: new ( datas. iter ( ) . collect ( ) , false , total_len) ;
201+ datas. iter ( ) . enumerate ( ) . for_each ( |( i, data) | {
203202 mutable. extend ( i, 0 , data. len ( ) ) ;
204203 } ) ;
205204 let array_ref = make_array ( mutable. freeze ( ) ) ;
You can’t perform that action at this time.
0 commit comments