You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ki...@apache.org on 2020/06/08 22:36:24 UTC
[hadoop] branch branch-2.8 updated: HADOOP-16255. Add
ChecksumFs.rename(path, path, boolean). Contributed by Jungtaek Lim.
This is an automated email from the ASF dual-hosted git repository.
kihwal pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-2.8 by this push:
new eb818cd HADOOP-16255. Add ChecksumFs.rename(path, path, boolean). Contributed by Jungtaek Lim.
eb818cd is described below
commit eb818cdc64336ade273a960ba3b9b5a5d0c4d4ec
Author: Kihwal Lee <ki...@apache.org>
AuthorDate: Mon Jun 8 17:36:10 2020 -0500
HADOOP-16255. Add ChecksumFs.rename(path, path, boolean). Contributed by Jungtaek Lim.
(cherry picked from commit 14ff6171a5879f63c1188b07cff8cbe135b9f802)
---
.../main/java/org/apache/hadoop/fs/ChecksumFs.java | 26 ++++++++++++++++++++++
1 file changed, 26 insertions(+)
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 @@ public abstract class ChecksumFs extends FilterFs {
}
}
+ @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.
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org