File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -187,7 +187,7 @@ impl TestParquetFile {
187187 ParquetSource :: new ( parquet_options)
188188 . with_predicate ( Arc :: clone ( & physical_filter_expr) ) ,
189189 )
190- . with_schema ( TableSchema :: new_from_file_schema ( Arc :: clone ( & self . schema ) ) ) ;
190+ . with_schema ( TableSchema :: from_file_schema ( Arc :: clone ( & self . schema ) ) ) ;
191191 let config = scan_config_builder. with_source ( source) . build ( ) ;
192192 let parquet_exec = DataSourceExec :: from_data_source ( config) ;
193193
Original file line number Diff line number Diff line change @@ -260,7 +260,7 @@ impl FileSource for CsvSource {
260260
261261 fn with_schema ( & self , schema : TableSchema ) -> Arc < dyn FileSource > {
262262 let mut conf = self . clone ( ) ;
263- conf. file_schema = Some ( Arc :: clone ( & schema. file_schema ( ) ) ) ;
263+ conf. file_schema = Some ( Arc :: clone ( schema. file_schema ( ) ) ) ;
264264 Arc :: new ( conf)
265265 }
266266
You can’t perform that action at this time.
0 commit comments