File tree Expand file tree Collapse file tree 1 file changed +10
-3
lines changed
datafusion/core/src/datasource/listing Expand file tree Collapse file tree 1 file changed +10
-3
lines changed Original file line number Diff line number Diff line change @@ -972,9 +972,16 @@ impl TableProvider for ListingTable {
972
972
// Apply schema adapter to source if available
973
973
apply_schema_adapter_to_source ( & mut source, self . schema_adapter_factory . clone ( ) ) ;
974
974
975
- // Create file scan config with schema adapter factory if available
976
- let config =
977
- FileScanConfig :: new ( object_store_url, Arc :: clone ( & self . file_schema ) , source)
975
+ // create the execution plan
976
+ self . options
977
+ . format
978
+ . create_physical_plan (
979
+ session_state,
980
+ FileScanConfigBuilder :: new (
981
+ object_store_url,
982
+ Arc :: clone ( & self . file_schema ) ,
983
+ source,
984
+ )
978
985
. with_file_groups ( partitioned_file_lists)
979
986
. with_constraints ( self . constraints . clone ( ) )
980
987
. with_statistics ( statistics)
You can’t perform that action at this time.
0 commit comments