This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new de450d4606 parquet:Add file_extension for specify file_extension of
ParquetReadOptions (#13353)
de450d4606 is described below
commit de450d46068bbc6f4e09df4fc156e5376c4f5ff1
Author: glfeng <[email protected]>
AuthorDate: Fri Nov 15 05:09:46 2024 +0800
parquet:Add file_extension for specify file_extension of ParquetReadOptions
(#13353)
* Add file_extension for specify file_extension of ParquetReadOptions
* remove whitespace in #270
---
datafusion/core/src/datasource/file_format/options.rs | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/datafusion/core/src/datasource/file_format/options.rs
b/datafusion/core/src/datasource/file_format/options.rs
index 1e0e28ef88..e392515cac 100644
--- a/datafusion/core/src/datasource/file_format/options.rs
+++ b/datafusion/core/src/datasource/file_format/options.rs
@@ -262,6 +262,12 @@ impl<'a> ParquetReadOptions<'a> {
Default::default()
}
+ /// Specify file_extension
+ pub fn file_extension(mut self, file_extension: &'a str) -> Self {
+ self.file_extension = file_extension;
+ self
+ }
+
/// Specify parquet_pruning
pub fn parquet_pruning(mut self, parquet_pruning: bool) -> Self {
self.parquet_pruning = Some(parquet_pruning);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
