File tree Expand file tree Collapse file tree 1 file changed +6
-10
lines changed Expand file tree Collapse file tree 1 file changed +6
-10
lines changed Original file line number Diff line number Diff line change @@ -172,23 +172,19 @@ impl PopulatedDeleteFileIndex {
172
172
deletes_queue. extend ( deletes. iter ( ) ) ;
173
173
}
174
174
175
- let mut results = vec ! [ ] ;
176
175
deletes_queue
177
176
. iter ( )
178
177
. filter ( |& delete| {
179
178
seq_num
180
179
. map ( |seq_num| delete. manifest_entry . sequence_number ( ) > Some ( seq_num) )
181
180
. unwrap_or_else ( || true )
182
181
} )
183
- . for_each ( |delete| {
184
- results. push ( FileScanTaskDeleteFile {
185
- file_path : delete. manifest_entry . file_path ( ) . to_string ( ) ,
186
- file_type : delete. manifest_entry . content_type ( ) ,
187
- partition_spec_id : delete. partition_spec_id ,
188
- } )
189
- } ) ;
190
-
191
- results
182
+ . map ( |delete| FileScanTaskDeleteFile {
183
+ file_path : delete. manifest_entry . file_path ( ) . to_string ( ) ,
184
+ file_type : delete. manifest_entry . content_type ( ) ,
185
+ partition_spec_id : delete. partition_spec_id ,
186
+ } )
187
+ . collect ( )
192
188
}
193
189
}
194
190
You can’t perform that action at this time.
0 commit comments