File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -83,11 +83,15 @@ pub(crate) fn init_datasource_exec(
8383 // dbg!(&required_schema, &data_schema);
8484
8585 // Determine the schema to use for ParquetSource
86- // Use data_schema only if both data_schema and data_filters are set
87- let base_schema = match ( & data_schema, & data_filters) {
88- ( Some ( schema) , Some ( _) ) => Arc :: clone ( schema) ,
89- _ => Arc :: clone ( & required_schema) ,
90- } ;
86+ // // Use data_schema only if both data_schema and data_filters are set
87+ // let base_schema = match (&data_schema, &data_filters) {
88+ // (Some(schema), Some(_)) => Arc::clone(schema),
89+ // _ => Arc::clone(&required_schema),
90+ // };
91+ let base_schema = required_schema;
92+ // dbg!(&base_schema);
93+ // dbg!(&data_schema);
94+ // dbg!(&data_filters);
9195 let partition_fields: Vec < _ > = partition_schema
9296 . iter ( )
9397 . flat_map ( |s| s. fields ( ) . iter ( ) )
You can’t perform that action at this time.
0 commit comments