blob: d73743f613b11a55970a2815ad2bf587273a2fd1 [file] [log] [blame]
diff --git a/shims/common/src/main/java/org/apache/hadoop/fs/ProxyFileSystem.java b/shims/common/src/main/java/org/apache/hadoop/fs/ProxyFileSystem.java
index 2c37a51cf4..c8122a2d61 100644
--- a/shims/common/src/main/java/org/apache/hadoop/fs/ProxyFileSystem.java
+++ b/shims/common/src/main/java/org/apache/hadoop/fs/ProxyFileSystem.java
@@ -23,6 +23,7 @@
import java.net.URISyntaxException;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.Options.Rename;
import org.apache.hadoop.fs.permission.FsPermission;
import org.apache.hadoop.util.Progressable;
import org.apache.hadoop.util.Shell;
@@ -180,6 +181,12 @@ public boolean rename(Path src, Path dst) throws IOException {
return super.isFile(dest) ? false : super.rename(swizzleParamPath(src), dest);
}
+ @Override
+ protected void rename(Path src, Path dst, Rename... options)
+ throws IOException {
+ super.rename(swizzleParamPath(src), swizzleParamPath(dst), options);
+ }
+
@Override
public boolean delete(Path f, boolean recursive) throws IOException {
return super.delete(swizzleParamPath(f), recursive);
@@ -215,6 +222,11 @@ public Path getWorkingDirectory() {
return swizzleReturnPath(super.getWorkingDirectory());
}
+ @Override
+ public boolean mkdirs(Path f) throws IOException {
+ return super.mkdirs(swizzleParamPath(f));
+ }
+
@Override
public boolean mkdirs(Path f, FsPermission permission) throws IOException {
return super.mkdirs(swizzleParamPath(f), permission);