HCFS recursively delete files

1 files changed, 7 insertions, 0 deletions

diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
index eddf9e89e..c4b5683ce 100644
--- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
+++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
@@ -116,6 +116,13 @@ public class SeaweedFileSystemStore {
             return true;
         }
 
+        if (recursive && isDirectroy) {
+            List<FilerProto.Entry> entries = lookupEntries(path);
+            for (FilerProto.Entry entry : entries) {
+                deleteEntries(new Path(path, entry.getName()), entry.getIsDirectory(), recursive);
+            }
+        }
+
         FilerProto.DeleteEntryResponse response =
             filerGrpcClient.getBlockingStub().deleteEntry(FilerProto.DeleteEntryRequest.newBuilder()
                 .setDirectory(getParentDirectory(path))