diff --git a/Cargo.toml b/Cargo.toml index 60307bd587..70eadf76db 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -67,7 +67,7 @@ log = "^0.4" mockito = "^1" murmur3 = "0.5.2" once_cell = "1" -opendal = "0.47" +opendal = "0.48" ordered-float = "4.0.0" parquet = "52" pilota = "0.11.2" diff --git a/crates/iceberg/src/io/storage_fs.rs b/crates/iceberg/src/io/storage_fs.rs index 0dc5b9dea4..19421569cd 100644 --- a/crates/iceberg/src/io/storage_fs.rs +++ b/crates/iceberg/src/io/storage_fs.rs @@ -45,7 +45,9 @@ impl FsConfig { /// /// fs always build from `/` pub fn build(&self, _: &str) -> Result { - let m = HashMap::from_iter([("root".to_string(), "/".to_string())]); - Ok(Operator::via_map(Scheme::Fs, m)?) + Ok(Operator::via_iter(Scheme::Fs, [( + "root".to_string(), + "/".to_string(), + )])?) } } diff --git a/crates/iceberg/src/io/storage_memory.rs b/crates/iceberg/src/io/storage_memory.rs index ed0cfadfe0..e160c237e1 100644 --- a/crates/iceberg/src/io/storage_memory.rs +++ b/crates/iceberg/src/io/storage_memory.rs @@ -40,6 +40,6 @@ impl MemoryConfig { /// Build new opendal operator from given path. pub fn build(&self, _: &str) -> Result { let m = HashMap::new(); - Ok(Operator::via_map(Scheme::Memory, m)?) + Ok(Operator::via_iter(Scheme::Memory, m)?) } } diff --git a/crates/iceberg/src/io/storage_s3.rs b/crates/iceberg/src/io/storage_s3.rs index df843188fd..9332f652a6 100644 --- a/crates/iceberg/src/io/storage_s3.rs +++ b/crates/iceberg/src/io/storage_s3.rs @@ -97,6 +97,6 @@ impl S3Config { ); m.insert("region".to_string(), self.region.clone()); - Ok(Operator::via_map(Scheme::S3, m)?) + Ok(Operator::via_iter(Scheme::S3, m)?) } } diff --git a/rustfmt.toml b/rustfmt.toml index 49be5742b6..91d924daf1 100644 --- a/rustfmt.toml +++ b/rustfmt.toml @@ -23,4 +23,4 @@ group_imports = "StdExternalCrate" imports_granularity = "Module" overflow_delimited_expr = true trailing_comma = "Vertical" -where_single_line = true \ No newline at end of file +where_single_line = true