Skip to content

Commit 64c1691

Browse files
committed
refactor: enhance schema adapter factory handling in ParquetSource
1 parent 7154234 commit 64c1691

File tree

1 file changed

+5
-2
lines changed
  • datafusion/core/src/datasource/listing

1 file changed

+5
-2
lines changed

datafusion/core/src/datasource/listing/table.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1222,8 +1222,11 @@ impl FileSourceExt for dyn FileSource {
12221222
factory: Option<Arc<dyn SchemaAdapterFactory>>,
12231223
) -> Arc<dyn FileSource> {
12241224
#[cfg(feature = "parquet")]
1225-
if let Some(ps) = self.as_any().downcast_ref::<ParquetSource>() {
1226-
return Arc::new(ps.clone().with_schema_adapter_factory(factory));
1225+
if let Some(source) = self.as_any().downcast_ref::<ParquetSource>() {
1226+
if let Some(f) = factory {
1227+
return Arc::new(source.clone().with_schema_adapter_factory(f));
1228+
}
1229+
return self;
12271230
}
12281231
self
12291232
}

0 commit comments

Comments
 (0)