diff --git a/datafusion/core/src/datasource/file_format/parquet.rs b/datafusion/core/src/datasource/file_format/parquet.rs index c35f59dd4a94..de3ec3ffb799 100644 --- a/datafusion/core/src/datasource/file_format/parquet.rs +++ b/datafusion/core/src/datasource/file_format/parquet.rs @@ -604,6 +604,7 @@ impl DisplayAs for ParquetSink { } /// Parses datafusion.execution.parquet.encoding String to a parquet::basic::Encoding +/// TODO use upstream version: fn parse_encoding_string(str_setting: &str) -> Result { let str_setting_lower: &str = &str_setting.to_lowercase(); match str_setting_lower { @@ -667,6 +668,7 @@ fn require_level(codec: &str, level: Option) -> Result { } /// Parses datafusion.execution.parquet.compression String to a parquet::basic::Compression +/// TODO use upstream version: fn parse_compression_string(str_setting: &str) -> Result { let str_setting_lower: &str = &str_setting.to_lowercase(); let (codec, level) = split_compression_string(str_setting_lower)?; @@ -717,6 +719,7 @@ fn parse_compression_string(str_setting: &str) -> Result fn parse_version_string(str_setting: &str) -> Result { let str_setting_lower: &str = &str_setting.to_lowercase(); match str_setting_lower { @@ -729,6 +732,7 @@ fn parse_version_string(str_setting: &str) -> Result { } } +/// TODO use upstream version: fn parse_statistics_string(str_setting: &str) -> Result { let str_setting_lower: &str = &str_setting.to_lowercase(); match str_setting_lower {