Skip to content

Commit 7b10340

Browse files
committed
fix style
1 parent b3b6b20 commit 7b10340

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

native/core/src/parquet/parquet_support.rs

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -38,13 +38,8 @@ use datafusion_comet_spark_expr::EvalMode;
3838
use object_store::path::Path;
3939
use object_store::{parse_url, ObjectStore};
4040
use std::collections::HashMap;
41-
use std::path::PathBuf;
4241
use std::time::Duration;
43-
use std::{
44-
fmt::{Debug, Write},
45-
hash::Hash,
46-
sync::Arc,
47-
};
42+
use std::{fmt::Debug, hash::Hash, sync::Arc};
4843
use url::Url;
4944

5045
use super::objectstore;
@@ -373,7 +368,9 @@ fn parse_hdfs_url(url: &Url) -> Result<(Box<dyn ObjectStore>, Path), object_stor
373368
Ok((Box::new(store), path))
374369
}
375370

371+
#[cfg(feature = "hdfs-opendal")]
376372
fn get_name_node_uri(url: &Url) -> Result<String, object_store::Error> {
373+
use std::fmt::Write;
377374
if let Some(host) = url.host() {
378375
let schema = url.scheme();
379376
let mut uri_builder = String::new();
@@ -386,7 +383,7 @@ fn get_name_node_uri(url: &Url) -> Result<String, object_store::Error> {
386383
} else {
387384
Err(object_store::Error::InvalidPath {
388385
source: object_store::path::Error::InvalidPath {
389-
path: PathBuf::from(url.as_str()),
386+
path: std::path::PathBuf::from(url.as_str()),
390387
},
391388
})
392389
}

0 commit comments

Comments
 (0)