File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -233,8 +233,7 @@ impl ArrowReader {
233
233
let mut column_indices = collector
234
234
. field_ids
235
235
. iter ( )
236
- . map ( |field_id| field_id_map. get ( field_id) . cloned ( ) )
237
- . flatten ( )
236
+ . filter_map ( |field_id| field_id_map. get ( field_id) . cloned ( ) )
238
237
. collect :: < Vec < _ > > ( ) ;
239
238
240
239
column_indices. sort ( ) ;
@@ -580,7 +579,7 @@ impl<'a> BoundPredicateVisitor for PredicateConverter<'a> {
580
579
reference : & BoundReference ,
581
580
_predicate : & BoundPredicate ,
582
581
) -> Result < Box < PredicateResult > > {
583
- if let Some ( _ ) = self . bound_reference ( reference) {
582
+ if self . bound_reference ( reference) . is_some ( ) {
584
583
self . build_always_true ( )
585
584
} else {
586
585
// A missing column, treating it as null.
@@ -593,7 +592,7 @@ impl<'a> BoundPredicateVisitor for PredicateConverter<'a> {
593
592
reference : & BoundReference ,
594
593
_predicate : & BoundPredicate ,
595
594
) -> Result < Box < PredicateResult > > {
596
- if let Some ( _ ) = self . bound_reference ( reference) {
595
+ if self . bound_reference ( reference) . is_some ( ) {
597
596
self . build_always_false ( )
598
597
} else {
599
598
// A missing column, treating it as null.
You can’t perform that action at this time.
0 commit comments