|
@@ -461,12 +461,19 @@ public class ViewFileSystem extends FileSystem {
|
|
|
suffix.length() == 0 ? f : new Path(res.resolvedPath, suffix));
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public boolean mkdirs(Path dir) throws IOException {
|
|
|
+ InodeTree.ResolveResult<FileSystem> res =
|
|
|
+ fsState.resolve(getUriPath(dir), false);
|
|
|
+ return res.targetFileSystem.mkdirs(res.remainingPath);
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public boolean mkdirs(final Path dir, final FsPermission permission)
|
|
|
throws IOException {
|
|
|
InodeTree.ResolveResult<FileSystem> res =
|
|
|
- fsState.resolve(getUriPath(dir), false);
|
|
|
- return res.targetFileSystem.mkdirs(res.remainingPath, permission);
|
|
|
+ fsState.resolve(getUriPath(dir), false);
|
|
|
+ return res.targetFileSystem.mkdirs(res.remainingPath, permission);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -1076,6 +1083,12 @@ public class ViewFileSystem extends FileSystem {
|
|
|
throw readOnlyMountTable("mkdirs", dir);
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public boolean mkdirs(Path dir)
|
|
|
+ throws AccessControlException, FileAlreadyExistsException {
|
|
|
+ return mkdirs(dir, null);
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public FSDataInputStream open(Path f, int bufferSize)
|
|
|
throws AccessControlException, FileNotFoundException, IOException {
|