Skip to content

Commit 7263d1b

Browse files
committed
address comments
1 parent b5a2a34 commit 7263d1b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

datafusion/datasource/src/source.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,11 @@ impl DataSourceExec {
232232
)
233233
}
234234

235-
/// Downcast the `DataSourceExec` to a specific file source
235+
/// Downcast the `DataSourceExec`'s `data_source` to a specific file source
236+
///
237+
/// Returns `None` if
238+
/// 1. the datasource is not scanning files (`FileScanConfig`)
239+
/// 2. The [`FileScanConfig::file_source`] is not of type `T`
236240
pub fn downcast_to_file_source<T: 'static>(&self) -> Option<(&FileScanConfig, &T)> {
237241
self.data_source()
238242
.as_any()

0 commit comments

Comments
 (0)