HADOOP-16255. Add ChecksumFs.rename(path, path, boolean). Contributed by Jungtaek Lim.
(cherry picked from commit 14ff6171a5879f63c1188b07cff8cbe135b9f802)
diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java
index 5c54554..ef262c8 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java
@@ -472,6 +472,32 @@
}
}
+ @Override
+ public void renameInternal(Path src, Path dst, boolean overwrite)
+ throws AccessControlException, FileAlreadyExistsException,
+ FileNotFoundException, ParentNotDirectoryException,
+ UnresolvedLinkException, IOException {
+ Options.Rename renameOpt = Options.Rename.NONE;
+ if (overwrite) {
+ renameOpt = Options.Rename.OVERWRITE;
+ }
+
+ if (isDirectory(src)) {
+ getMyFs().rename(src, dst, renameOpt);
+ } else {
+ getMyFs().rename(src, dst, renameOpt);
+
+ Path checkFile = getChecksumFile(src);
+ if (exists(checkFile)) { //try to rename checksum
+ if (isDirectory(dst)) {
+ getMyFs().rename(checkFile, dst, renameOpt);
+ } else {
+ getMyFs().rename(checkFile, getChecksumFile(dst), renameOpt);
+ }
+ }
+ }
+ }
+
/**
* Implement the delete(Path, boolean) in checksum
* file system.
