1 files changed, 10 insertions, 0 deletions
diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
index f2dd01385..40f152b4f 100644
--- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
+++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
@@ -65,6 +65,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         seaweedFileSystemStore = new SeaweedFileSystemStore(host, port);
     }
 
+    @Override
     public FSDataInputStream open(Path path, int bufferSize) throws IOException {
 
         LOG.debug("open path: {} bufferSize:{}", path, bufferSize);
@@ -79,6 +80,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         }
     }
 
+    @Override
     public FSDataOutputStream create(Path path, FsPermission permission, final boolean overwrite, final int bufferSize,
                                      final short replication, final long blockSize, final Progressable progress) throws IOException {
 
@@ -95,6 +97,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         }
     }
 
+    @Override
     public FSDataOutputStream append(Path path, int bufferSize, Progressable progressable) throws IOException {
 
         LOG.debug("append path: {} bufferSize:{}", path, bufferSize);
@@ -108,6 +111,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         }
     }
 
+    @Override
     public boolean rename(Path src, Path dst) {
 
         LOG.debug("rename path: {} => {}", src, dst);
@@ -138,6 +142,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         return true;
     }
 
+    @Override
     public boolean delete(Path path, boolean recursive) {
 
         LOG.debug("delete path: {} recursive:{}", path, recursive);
@@ -154,6 +159,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
 
     }
 
+    @Override
     public FileStatus[] listStatus(Path path) throws IOException {
 
         LOG.debug("listStatus path: {}", path);
@@ -163,10 +169,12 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         return seaweedFileSystemStore.listEntries(path);
     }
 
+    @Override
     public Path getWorkingDirectory() {
         return workingDirectory;
     }
 
+    @Override
     public void setWorkingDirectory(Path path) {
         if (path.isAbsolute()) {
             workingDirectory = path;
@@ -175,6 +183,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         }
     }
 
+    @Override
     public boolean mkdirs(Path path, FsPermission fsPermission) throws IOException {
 
         LOG.debug("mkdirs path: {}", path);
@@ -199,6 +208,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem {
         }
     }
 
+    @Override
     public FileStatus getFileStatus(Path path) {
 
         LOG.debug("getFileStatus path: {}", path);