File tree Expand file tree Collapse file tree
datafusion/datasource/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -422,7 +422,7 @@ impl From<FileScanConfig> for FileScanConfigBuilder {
422422 Self {
423423 object_store_url : config. object_store_url ,
424424 file_schema : config. file_schema ,
425- file_source : config. file_source . clone ( ) ,
425+ file_source : Arc :: < dyn FileSource > :: clone ( & config. file_source ) ,
426426 file_groups : config. file_groups ,
427427 statistics : config. file_source . statistics ( ) . ok ( ) ,
428428 output_ordering : config. output_ordering ,
@@ -2157,10 +2157,21 @@ mod tests {
21572157 assert ! ( config. constraints. is_empty( ) ) ;
21582158
21592159 // Verify statistics are set to unknown
2160- assert_eq ! ( config. file_source. statistics( ) . unwrap( ) . num_rows, Precision :: Absent ) ;
2161- assert_eq ! ( config. file_source. statistics( ) . unwrap( ) . total_byte_size, Precision :: Absent ) ;
21622160 assert_eq ! (
2163- config. file_source. statistics( ) . unwrap( ) . column_statistics. len( ) ,
2161+ config. file_source. statistics( ) . unwrap( ) . num_rows,
2162+ Precision :: Absent
2163+ ) ;
2164+ assert_eq ! (
2165+ config. file_source. statistics( ) . unwrap( ) . total_byte_size,
2166+ Precision :: Absent
2167+ ) ;
2168+ assert_eq ! (
2169+ config
2170+ . file_source
2171+ . statistics( )
2172+ . unwrap( )
2173+ . column_statistics
2174+ . len( ) ,
21642175 file_schema. fields( ) . len( )
21652176 ) ;
21662177 for stat in config. file_source . statistics ( ) . unwrap ( ) . column_statistics {
You can’t perform that action at this time.
0 commit comments