MCPcopy Create free account
hub / github.com/apache/datafusion / list_all_files

Method list_all_files

datafusion/datasource/src/url.rs:307–315  ·  view source on GitHub ↗

List all files identified by this [`ListingTableUrl`] for the provided `file_extension`

(
        &'a self,
        ctx: &'a dyn Session,
        store: &'a dyn ObjectStore,
        file_extension: &'a str,
    )

Source from the content-addressed store, hash-verified

305
306 /// List all files identified by this [`ListingTableUrl`] for the provided `file_extension`
307 pub async fn list_all_files<'a>(
308 &'a self,
309 ctx: &'a dyn Session,
310 store: &'a dyn ObjectStore,
311 file_extension: &'a str,
312 ) -> Result<BoxStream<'a, Result<ObjectMeta>>> {
313 self.list_prefixed_files(ctx, store, None, file_extension)
314 .await
315 }
316
317 /// Returns this [`ListingTableUrl`] as a string
318 pub fn as_str(&self) -> &str {

Callers 3

infer_optionsMethod · 0.80
infer_schemaMethod · 0.80
infer_partitionsMethod · 0.80

Calls 1

list_prefixed_filesMethod · 0.80

Tested by

no test coverage detected