lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-02-09 09:17:28 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #34 from chrislusf/master

Browse Source 
sync
This commit is contained in:
hilimd
2020-11-05 12:02:47 +08:00
committed by GitHub
parent 843865f2ca 75887ba2a2
commit 546f1bcb90
50 changed files with 973 additions and 224 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
View File

@@ -65,6 +65,12 @@ public class SeaweedFileSystem extends FileSystem {
}
@Override
public void close() throws IOException {
this.seaweedFileSystemStore.close();
super.close();
}
@Override
public FSDataInputStream open(Path path, int bufferSize) throws IOException {

8
other/java/hdfs2/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
View File

@@ -36,6 +36,14 @@ public class SeaweedFileSystemStore {
this.conf = conf;
}
public void close() {
try {
this.filerGrpcClient.shutdown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static String getParentDirectory(Path path) {
return path.isRoot() ? "/" : path.getParent().toUri().getPath();
}

6
other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystem.java
View File

@@ -65,6 +65,12 @@ public class SeaweedFileSystem extends FileSystem {
}
@Override
public void close() throws IOException {
this.seaweedFileSystemStore.close();
super.close();
}
@Override
public FSDataInputStream open(Path path, int bufferSize) throws IOException {

8
other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java
View File

@@ -36,6 +36,14 @@ public class SeaweedFileSystemStore {
this.conf = conf;
}
public void close() {
try {
this.filerGrpcClient.shutdown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static String getParentDirectory(Path path) {
return path.isRoot() ? "/" : path.getParent().toUri().getPath();
}