File tree Expand file tree Collapse file tree 6 files changed +14
-11
lines changed
physical-expr/src/equivalence/properties Expand file tree Collapse file tree 6 files changed +14
-11
lines changed Original file line number Diff line number Diff line change @@ -73,7 +73,7 @@ license = "Apache-2.0"
7373readme = " README.md"
7474repository = " https://github.com/apache/datafusion"
7575# Define Minimum Supported Rust Version (MSRV)
76- rust-version = " 1.82 .0"
76+ rust-version = " 1.81 .0"
7777# Define DataFusion version
7878version = " 47.0.0"
7979
Original file line number Diff line number Diff line change @@ -193,16 +193,17 @@ impl TableReference {
193193 match self {
194194 TableReference :: Bare { table } => * * table == * other. table ( ) ,
195195 TableReference :: Partial { schema, table } => {
196- * * table == * other. table ( ) && other. schema ( ) . is_none_or ( |s| * s == * * schema)
196+ * * table == * other. table ( )
197+ && other. schema ( ) . map_or ( true , |s| * s == * * schema)
197198 }
198199 TableReference :: Full {
199200 catalog,
200201 schema,
201202 table,
202203 } => {
203204 * * table == * other. table ( )
204- && other. schema ( ) . is_none_or ( |s| * s == * * schema)
205- && other. catalog ( ) . is_none_or ( |c| * c == * * catalog)
205+ && other. schema ( ) . map_or ( true , |s| * s == * * schema)
206+ && other. catalog ( ) . map_or ( true , |c| * c == * * catalog)
206207 }
207208 }
208209 }
Original file line number Diff line number Diff line change @@ -571,9 +571,9 @@ where
571571 for ( idx_in_val, group_idx) in group_indices. iter ( ) . enumerate ( ) {
572572 let group_idx = * group_idx;
573573
574- let passed_filter = opt_filter. is_none_or ( |x| x. value ( idx_in_val) ) ;
574+ let passed_filter = opt_filter. map_or ( true , |x| x. value ( idx_in_val) ) ;
575575
576- let is_set = is_set_arr. is_none_or ( |x| x. value ( idx_in_val) ) ;
576+ let is_set = is_set_arr. map_or ( true , |x| x. value ( idx_in_val) ) ;
577577
578578 if !passed_filter || !is_set {
579579 continue ;
Original file line number Diff line number Diff line change @@ -183,11 +183,13 @@ impl PhysicalSortExpr {
183183 let nullable = self . expr . nullable ( schema) . unwrap_or ( true ) ;
184184 self . expr . eq ( & requirement. expr )
185185 && if nullable {
186- requirement. options . is_none_or ( |opts| self . options == opts)
186+ requirement
187+ . options
188+ . map_or ( true , |opts| self . options == opts)
187189 } else {
188190 requirement
189191 . options
190- . is_none_or ( |opts| self . options . descending == opts. descending )
192+ . map_or ( true , |opts| self . options . descending == opts. descending )
191193 }
192194 }
193195}
@@ -302,7 +304,7 @@ impl PhysicalSortRequirement {
302304 self . expr . eq ( & other. expr )
303305 && other
304306 . options
305- . is_none_or ( |other_opts| self . options == Some ( other_opts) )
307+ . map_or ( true , |other_opts| self . options == Some ( other_opts) )
306308 }
307309
308310 #[ deprecated( since = "43.0.0" , note = "use LexRequirement::from_lex_ordering" ) ]
Original file line number Diff line number Diff line change @@ -680,7 +680,7 @@ impl EquivalenceProperties {
680680 req. expr . eq ( & existing. expr )
681681 && req
682682 . options
683- . is_none_or ( |req_opts| req_opts == existing. options )
683+ . map_or ( true , |req_opts| req_opts == existing. options )
684684 } ,
685685 )
686686 } )
Original file line number Diff line number Diff line change 1919# to compile this workspace and run CI jobs.
2020
2121[toolchain ]
22- channel = " 1.86.0 "
22+ channel = " 1.84.1 "
2323components = [" rustfmt" , " clippy" ]
You can’t perform that action at this time.
0 commit comments