diff --git a/datafusion/core/src/datasource/listing/table.rs b/datafusion/core/src/datasource/listing/table.rs index 7ac94e8d913b..832d8a65dd93 100644 --- a/datafusion/core/src/datasource/listing/table.rs +++ b/datafusion/core/src/datasource/listing/table.rs @@ -114,6 +114,10 @@ impl ListingTableConfig { } } + ///Returns a tupe of (file_extension, optional compression_extension) + /// + /// For example a path ending with blah.test.csv.gz returns `("csv", Some("gz"))` + /// For example a path ending with blah.test.csv returns `("csv", None)` fn infer_file_extension_and_compression_type( path: &str, ) -> Result<(String, Option)> {