rename to delete_prefix

Author: CTTY

crates/iceberg/src/io/file_io.rs

@@ -106,8 +106,8 @@ impl FileIO {
     /// - If the path is a file or not exist, this function will be no-op.
     /// - If the path is a empty directory, this function will remove the directory itself.
     /// - If the path is a non-empty directory, this function will remove the directory and all nested files and directories.
-    pub async fn remove_dir_all(&self, path: impl AsRef<str>) -> Result<()> {
-        self.inner.remove_dir_all(path.as_ref()).await
+    pub async fn delete_prefix(&self, path: impl AsRef<str>) -> Result<()> {
+        self.inner.delete_prefix(path.as_ref()).await
     }
 
     /// Check file exists.
@@ -594,7 +594,7 @@ mod tests {
             Ok(())
         }
 
-        async fn remove_dir_all(&self, _path: &str) -> Result<()> {
+        async fn delete_prefix(&self, _path: &str) -> Result<()> {
             Ok(())
         }
 
@@ -692,14 +692,14 @@ mod tests {
         assert!(file_io.exists(&a_path).await.unwrap());
 
         // Remove a file should be no-op.
-        file_io.remove_dir_all(&a_path).await.unwrap();
+        file_io.delete_prefix(&a_path).await.unwrap();
         assert!(file_io.exists(&a_path).await.unwrap());
 
         // Remove a not exist dir should be no-op.
-        file_io.remove_dir_all("not_exists/").await.unwrap();
+        file_io.delete_prefix("not_exists/").await.unwrap();
 
         // Remove a dir should remove all files in it.
-        file_io.remove_dir_all(&sub_dir_path).await.unwrap();
+        file_io.delete_prefix(&sub_dir_path).await.unwrap();
         assert!(!file_io.exists(&b_path).await.unwrap());
         assert!(!file_io.exists(&c_path).await.unwrap());
         assert!(file_io.exists(&a_path).await.unwrap());
@@ -718,7 +718,7 @@ mod tests {
         let file_io = create_local_file_io();
         assert!(!file_io.exists(&full_path).await.unwrap());
         assert!(file_io.delete(&full_path).await.is_ok());
-        assert!(file_io.remove_dir_all(&full_path).await.is_ok());
+        assert!(file_io.delete_prefix(&full_path).await.is_ok());
     }
 
     #[tokio::test]

crates/iceberg/src/io/storage.rs

@@ -77,8 +77,8 @@ pub trait Storage: Debug + Send + Sync {
     /// Delete a file at the given path
     async fn delete(&self, path: &str) -> Result<()>;
 
-    /// Remove a directory and all its contents recursively
-    async fn remove_dir_all(&self, path: &str) -> Result<()>;
+    /// Delete all files with the given prefix
+    async fn delete_prefix(&self, path: &str) -> Result<()>;
 
     /// Create a new input file for reading
     fn new_input(&self, path: &str) -> Result<InputFile>;

crates/iceberg/src/io/storage_azdls.rs

@@ -668,7 +668,7 @@ impl Storage for OpenDALAzdlsStorage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let (op, relative_path) = self.create_operator(path)?;
         let path = if relative_path.ends_with('/') {
             relative_path.to_string()

crates/iceberg/src/io/storage_fs.rs

@@ -102,7 +102,7 @@ impl Storage for OpenDALFsStorage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let relative_path = self.extract_relative_path(path);
         let op = fs_config_build()?;
         let path = if relative_path.ends_with('/') {

crates/iceberg/src/io/storage_gcs.rs

@@ -180,7 +180,7 @@ impl Storage for OpenDALGcsStorage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let (op, relative_path) = self.create_operator(path)?;
         let path = if relative_path.ends_with('/') {
             relative_path.to_string()

crates/iceberg/src/io/storage_memory.rs

@@ -120,7 +120,7 @@ impl Storage for OpenDALMemoryStorage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let op = self.get_operator()?;
         let relative_path = self.extract_relative_path(path);
         let path = if relative_path.ends_with('/') {

crates/iceberg/src/io/storage_oss.rs

@@ -140,7 +140,7 @@ impl Storage for OpenDALOssStorage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let (op, relative_path) = self.create_operator(path)?;
         let path = if relative_path.ends_with('/') {
             relative_path.to_string()

crates/iceberg/src/io/storage_s3.rs

@@ -308,7 +308,7 @@ impl Storage for OpenDALS3Storage {
         Ok(op.delete(relative_path).await?)
     }
 
-    async fn remove_dir_all(&self, path: &str) -> Result<()> {
+    async fn delete_prefix(&self, path: &str) -> Result<()> {
         let (op, relative_path) = self.create_operator(path)?;
         let path = if relative_path.ends_with('/') {
             relative_path.to_string()