hadoop git commit: HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query result. Contributed by Ajay Kumar.

2018-03-12 Thread xyao 
Repository: hadoop
Updated Branches:
  refs/heads/branch-3.0 840c83bf7 -> 2a93ba690


HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query 
result. Contributed by Ajay Kumar.

(cherry picked from commit 107c177782a24a16c66113841f2fc5144f56207b)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/2a93ba69
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/2a93ba69
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/2a93ba69

Branch: refs/heads/branch-3.0
Commit: 2a93ba690c61965bdf5df7e893bf21b3b2445367
Parents: 840c83b
Author: Xiaoyu Yao 
Authored: Tue Oct 3 13:02:12 2017 -0700
Committer: Xiaoyu Yao 
Committed: Mon Mar 12 20:23:52 2018 -0700

--
 .../java/org/apache/hadoop/fs/FileStatus.java   | 27 +++-
 .../apache/hadoop/fs/protocolPB/PBHelper.java   | 14 +++---
 .../hadoop-common/src/main/proto/FSProtos.proto |  7 ++---
 .../hadoop/hdfs/protocol/HdfsFileStatus.java| 12 -
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  5 
 .../src/main/proto/hdfs.proto   |  1 +
 .../hadoop/fs/http/client/HttpFSFileSystem.java | 17 +---
 ...tNamenodeProtocolServerSideTranslatorPB.java |  1 +
 .../server/namenode/FSDirStatAndListingOp.java  |  7 +
 .../org/apache/hadoop/hdfs/web/JsonUtil.java|  4 +++
 .../hadoop-hdfs/src/site/markdown/WebHDFS.md|  2 ++
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 19 ++
 12 files changed, 103 insertions(+), 13 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/2a93ba69/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
index 78312b3..35f5316 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
@@ -60,7 +60,8 @@ public class FileStatus implements Writable, 
Comparable,
 HAS_ACL,
 HAS_CRYPT,
 HAS_EC,
-  };
+SNAPSHOT_ENABLED
+  }
   private static final Set NONE = Collections.emptySet();
   private static Set flags(boolean acl, boolean crypt, boolean ec) {
 if (!(acl || crypt || ec)) {
@@ -274,6 +275,15 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Check if directory is Snapshot enabled or not.
+   *
+   * @return true if directory is snapshot enabled
+   */
+  public boolean isSnapshotEnabled() {
+return attr.contains(AttrFlags.SNAPSHOT_ENABLED);
+  }
+
+  /**
* Get the owner of the file.
* @return owner of the file. The string could be empty if there is no
* notion of owner of a file in a filesystem or if it could not 
@@ -331,6 +341,19 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Sets Snapshot enabled flag.
+   *
+   * @param isSnapShotEnabled When true, SNAPSHOT_ENABLED flag is set
+   */
+  public void setSnapShotEnabledFlag(boolean isSnapShotEnabled) {
+if (isSnapShotEnabled) {
+  attr.add(AttrFlags.SNAPSHOT_ENABLED);
+} else {
+  attr.remove(AttrFlags.SNAPSHOT_ENABLED);
+}
+  }
+
+  /**
* @return The contents of the symbolic link.
*/
   public Path getSymlink() throws IOException {
@@ -486,4 +509,6 @@ public class FileStatus implements Writable, 
Comparable,
 }
   }
 
+
+
 }

http://git-wip-us.apache.org/repos/asf/hadoop/blob/2a93ba69/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
index aa7d8f5..23caf2e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
@@ -94,11 +94,15 @@ public final class PBHelper {
 owner = proto.getOwner();
 group = proto.getGroup();
 int flags = proto.getFlags();
-return new FileStatus(length, isdir, blockReplication, blocksize,
-mtime, atime, permission, owner, group, symlink, path,
-(flags & FileStatusProto.Flags.HAS_ACL_VALUE)   != 0,
+FileStatus fileStatus = new FileStatus(length, isdir, blockReplication,
+blocksize, mtime, atime, permission, owner, group, symlink, path,
+(flags & FileStatusProto.Flags.HAS_

[03/50] [abbrv] hadoop git commit: HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query result. Contributed by Ajay Kumar.

2017-10-06 Thread jhung 
HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query 
result. Contributed by Ajay Kumar.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/107c1777
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/107c1777
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/107c1777

Branch: refs/heads/YARN-5734
Commit: 107c177782a24a16c66113841f2fc5144f56207b
Parents: b913051
Author: Xiaoyu Yao 
Authored: Tue Oct 3 13:02:12 2017 -0700
Committer: Xiaoyu Yao 
Committed: Tue Oct 3 13:02:12 2017 -0700

--
 .../java/org/apache/hadoop/fs/FileStatus.java   | 27 +++-
 .../apache/hadoop/fs/protocolPB/PBHelper.java   | 14 +++---
 .../hadoop-common/src/main/proto/FSProtos.proto |  7 ++---
 .../hadoop/hdfs/protocol/HdfsFileStatus.java| 12 -
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  5 
 .../src/main/proto/hdfs.proto   |  1 +
 .../hadoop/fs/http/client/HttpFSFileSystem.java | 17 +---
 ...tNamenodeProtocolServerSideTranslatorPB.java |  1 +
 .../server/namenode/FSDirStatAndListingOp.java  |  7 +
 .../org/apache/hadoop/hdfs/web/JsonUtil.java|  4 +++
 .../hadoop-hdfs/src/site/markdown/WebHDFS.md|  2 ++
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 19 ++
 12 files changed, 103 insertions(+), 13 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
index 8575439..d7c05d7 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
@@ -60,7 +60,8 @@ public class FileStatus implements Writable, 
Comparable,
 HAS_ACL,
 HAS_CRYPT,
 HAS_EC,
-  };
+SNAPSHOT_ENABLED
+  }
   private static final Set NONE = Collections.emptySet();
   private static Set flags(boolean acl, boolean crypt, boolean ec) {
 if (!(acl || crypt || ec)) {
@@ -274,6 +275,15 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Check if directory is Snapshot enabled or not.
+   *
+   * @return true if directory is snapshot enabled
+   */
+  public boolean isSnapshotEnabled() {
+return attr.contains(AttrFlags.SNAPSHOT_ENABLED);
+  }
+
+  /**
* Get the owner of the file.
* @return owner of the file. The string could be empty if there is no
* notion of owner of a file in a filesystem or if it could not 
@@ -331,6 +341,19 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Sets Snapshot enabled flag.
+   *
+   * @param isSnapShotEnabled When true, SNAPSHOT_ENABLED flag is set
+   */
+  public void setSnapShotEnabledFlag(boolean isSnapShotEnabled) {
+if (isSnapShotEnabled) {
+  attr.add(AttrFlags.SNAPSHOT_ENABLED);
+} else {
+  attr.remove(AttrFlags.SNAPSHOT_ENABLED);
+}
+  }
+
+  /**
* @return The contents of the symbolic link.
*/
   public Path getSymlink() throws IOException {
@@ -486,4 +509,6 @@ public class FileStatus implements Writable, 
Comparable,
 }
   }
 
+
+
 }

http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
index aa7d8f5..23caf2e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
@@ -94,11 +94,15 @@ public final class PBHelper {
 owner = proto.getOwner();
 group = proto.getGroup();
 int flags = proto.getFlags();
-return new FileStatus(length, isdir, blockReplication, blocksize,
-mtime, atime, permission, owner, group, symlink, path,
-(flags & FileStatusProto.Flags.HAS_ACL_VALUE)   != 0,
+FileStatus fileStatus = new FileStatus(length, isdir, blockReplication,
+blocksize, mtime, atime, permission, owner, group, symlink, path,
+(flags & FileStatusProto.Flags.HAS_ACL_VALUE) != 0,
 (flags & FileStatusProto.Flags.HAS_CRYPT_VALUE) != 0,
-(flags & FileStatusProto.Flags.HAS_EC_VALUE)!= 0);
+(flag

[05/50] [abbrv] hadoop git commit: HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query result. Contributed by Ajay Kumar.

2017-10-05 Thread inigoiri 
HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query 
result. Contributed by Ajay Kumar.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/107c1777
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/107c1777
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/107c1777

Branch: refs/heads/HDFS-10467
Commit: 107c177782a24a16c66113841f2fc5144f56207b
Parents: b913051
Author: Xiaoyu Yao 
Authored: Tue Oct 3 13:02:12 2017 -0700
Committer: Xiaoyu Yao 
Committed: Tue Oct 3 13:02:12 2017 -0700

--
 .../java/org/apache/hadoop/fs/FileStatus.java   | 27 +++-
 .../apache/hadoop/fs/protocolPB/PBHelper.java   | 14 +++---
 .../hadoop-common/src/main/proto/FSProtos.proto |  7 ++---
 .../hadoop/hdfs/protocol/HdfsFileStatus.java| 12 -
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  5 
 .../src/main/proto/hdfs.proto   |  1 +
 .../hadoop/fs/http/client/HttpFSFileSystem.java | 17 +---
 ...tNamenodeProtocolServerSideTranslatorPB.java |  1 +
 .../server/namenode/FSDirStatAndListingOp.java  |  7 +
 .../org/apache/hadoop/hdfs/web/JsonUtil.java|  4 +++
 .../hadoop-hdfs/src/site/markdown/WebHDFS.md|  2 ++
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 19 ++
 12 files changed, 103 insertions(+), 13 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
index 8575439..d7c05d7 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
@@ -60,7 +60,8 @@ public class FileStatus implements Writable, 
Comparable,
 HAS_ACL,
 HAS_CRYPT,
 HAS_EC,
-  };
+SNAPSHOT_ENABLED
+  }
   private static final Set NONE = Collections.emptySet();
   private static Set flags(boolean acl, boolean crypt, boolean ec) {
 if (!(acl || crypt || ec)) {
@@ -274,6 +275,15 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Check if directory is Snapshot enabled or not.
+   *
+   * @return true if directory is snapshot enabled
+   */
+  public boolean isSnapshotEnabled() {
+return attr.contains(AttrFlags.SNAPSHOT_ENABLED);
+  }
+
+  /**
* Get the owner of the file.
* @return owner of the file. The string could be empty if there is no
* notion of owner of a file in a filesystem or if it could not 
@@ -331,6 +341,19 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Sets Snapshot enabled flag.
+   *
+   * @param isSnapShotEnabled When true, SNAPSHOT_ENABLED flag is set
+   */
+  public void setSnapShotEnabledFlag(boolean isSnapShotEnabled) {
+if (isSnapShotEnabled) {
+  attr.add(AttrFlags.SNAPSHOT_ENABLED);
+} else {
+  attr.remove(AttrFlags.SNAPSHOT_ENABLED);
+}
+  }
+
+  /**
* @return The contents of the symbolic link.
*/
   public Path getSymlink() throws IOException {
@@ -486,4 +509,6 @@ public class FileStatus implements Writable, 
Comparable,
 }
   }
 
+
+
 }

http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
index aa7d8f5..23caf2e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
@@ -94,11 +94,15 @@ public final class PBHelper {
 owner = proto.getOwner();
 group = proto.getGroup();
 int flags = proto.getFlags();
-return new FileStatus(length, isdir, blockReplication, blocksize,
-mtime, atime, permission, owner, group, symlink, path,
-(flags & FileStatusProto.Flags.HAS_ACL_VALUE)   != 0,
+FileStatus fileStatus = new FileStatus(length, isdir, blockReplication,
+blocksize, mtime, atime, permission, owner, group, symlink, path,
+(flags & FileStatusProto.Flags.HAS_ACL_VALUE) != 0,
 (flags & FileStatusProto.Flags.HAS_CRYPT_VALUE) != 0,
-(flags & FileStatusProto.Flags.HAS_EC_VALUE)!= 0);
+(fla

[48/50] [abbrv] hadoop git commit: HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query result. Contributed by Ajay Kumar.

2017-10-03 Thread kkaranasos 
HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query 
result. Contributed by Ajay Kumar.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/107c1777
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/107c1777
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/107c1777

Branch: refs/heads/YARN-6592
Commit: 107c177782a24a16c66113841f2fc5144f56207b
Parents: b913051
Author: Xiaoyu Yao 
Authored: Tue Oct 3 13:02:12 2017 -0700
Committer: Xiaoyu Yao 
Committed: Tue Oct 3 13:02:12 2017 -0700

--
 .../java/org/apache/hadoop/fs/FileStatus.java   | 27 +++-
 .../apache/hadoop/fs/protocolPB/PBHelper.java   | 14 +++---
 .../hadoop-common/src/main/proto/FSProtos.proto |  7 ++---
 .../hadoop/hdfs/protocol/HdfsFileStatus.java| 12 -
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  5 
 .../src/main/proto/hdfs.proto   |  1 +
 .../hadoop/fs/http/client/HttpFSFileSystem.java | 17 +---
 ...tNamenodeProtocolServerSideTranslatorPB.java |  1 +
 .../server/namenode/FSDirStatAndListingOp.java  |  7 +
 .../org/apache/hadoop/hdfs/web/JsonUtil.java|  4 +++
 .../hadoop-hdfs/src/site/markdown/WebHDFS.md|  2 ++
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 19 ++
 12 files changed, 103 insertions(+), 13 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
index 8575439..d7c05d7 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
@@ -60,7 +60,8 @@ public class FileStatus implements Writable, 
Comparable,
 HAS_ACL,
 HAS_CRYPT,
 HAS_EC,
-  };
+SNAPSHOT_ENABLED
+  }
   private static final Set NONE = Collections.emptySet();
   private static Set flags(boolean acl, boolean crypt, boolean ec) {
 if (!(acl || crypt || ec)) {
@@ -274,6 +275,15 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Check if directory is Snapshot enabled or not.
+   *
+   * @return true if directory is snapshot enabled
+   */
+  public boolean isSnapshotEnabled() {
+return attr.contains(AttrFlags.SNAPSHOT_ENABLED);
+  }
+
+  /**
* Get the owner of the file.
* @return owner of the file. The string could be empty if there is no
* notion of owner of a file in a filesystem or if it could not 
@@ -331,6 +341,19 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Sets Snapshot enabled flag.
+   *
+   * @param isSnapShotEnabled When true, SNAPSHOT_ENABLED flag is set
+   */
+  public void setSnapShotEnabledFlag(boolean isSnapShotEnabled) {
+if (isSnapShotEnabled) {
+  attr.add(AttrFlags.SNAPSHOT_ENABLED);
+} else {
+  attr.remove(AttrFlags.SNAPSHOT_ENABLED);
+}
+  }
+
+  /**
* @return The contents of the symbolic link.
*/
   public Path getSymlink() throws IOException {
@@ -486,4 +509,6 @@ public class FileStatus implements Writable, 
Comparable,
 }
   }
 
+
+
 }

http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
index aa7d8f5..23caf2e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
@@ -94,11 +94,15 @@ public final class PBHelper {
 owner = proto.getOwner();
 group = proto.getGroup();
 int flags = proto.getFlags();
-return new FileStatus(length, isdir, blockReplication, blocksize,
-mtime, atime, permission, owner, group, symlink, path,
-(flags & FileStatusProto.Flags.HAS_ACL_VALUE)   != 0,
+FileStatus fileStatus = new FileStatus(length, isdir, blockReplication,
+blocksize, mtime, atime, permission, owner, group, symlink, path,
+(flags & FileStatusProto.Flags.HAS_ACL_VALUE) != 0,
 (flags & FileStatusProto.Flags.HAS_CRYPT_VALUE) != 0,
-(flags & FileStatusProto.Flags.HAS_EC_VALUE)!= 0);
+(flag

hadoop git commit: HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query result. Contributed by Ajay Kumar.

2017-10-03 Thread xyao 
Repository: hadoop
Updated Branches:
  refs/heads/trunk b91305119 -> 107c17778


HDFS-12455. WebHDFS - Adding "snapshot enabled" status to ListStatus query 
result. Contributed by Ajay Kumar.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/107c1777
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/107c1777
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/107c1777

Branch: refs/heads/trunk
Commit: 107c177782a24a16c66113841f2fc5144f56207b
Parents: b913051
Author: Xiaoyu Yao 
Authored: Tue Oct 3 13:02:12 2017 -0700
Committer: Xiaoyu Yao 
Committed: Tue Oct 3 13:02:12 2017 -0700

--
 .../java/org/apache/hadoop/fs/FileStatus.java   | 27 +++-
 .../apache/hadoop/fs/protocolPB/PBHelper.java   | 14 +++---
 .../hadoop-common/src/main/proto/FSProtos.proto |  7 ++---
 .../hadoop/hdfs/protocol/HdfsFileStatus.java| 12 -
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  5 
 .../src/main/proto/hdfs.proto   |  1 +
 .../hadoop/fs/http/client/HttpFSFileSystem.java | 17 +---
 ...tNamenodeProtocolServerSideTranslatorPB.java |  1 +
 .../server/namenode/FSDirStatAndListingOp.java  |  7 +
 .../org/apache/hadoop/hdfs/web/JsonUtil.java|  4 +++
 .../hadoop-hdfs/src/site/markdown/WebHDFS.md|  2 ++
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 19 ++
 12 files changed, 103 insertions(+), 13 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
index 8575439..d7c05d7 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileStatus.java
@@ -60,7 +60,8 @@ public class FileStatus implements Writable, 
Comparable,
 HAS_ACL,
 HAS_CRYPT,
 HAS_EC,
-  };
+SNAPSHOT_ENABLED
+  }
   private static final Set NONE = Collections.emptySet();
   private static Set flags(boolean acl, boolean crypt, boolean ec) {
 if (!(acl || crypt || ec)) {
@@ -274,6 +275,15 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Check if directory is Snapshot enabled or not.
+   *
+   * @return true if directory is snapshot enabled
+   */
+  public boolean isSnapshotEnabled() {
+return attr.contains(AttrFlags.SNAPSHOT_ENABLED);
+  }
+
+  /**
* Get the owner of the file.
* @return owner of the file. The string could be empty if there is no
* notion of owner of a file in a filesystem or if it could not 
@@ -331,6 +341,19 @@ public class FileStatus implements Writable, 
Comparable,
   }
 
   /**
+   * Sets Snapshot enabled flag.
+   *
+   * @param isSnapShotEnabled When true, SNAPSHOT_ENABLED flag is set
+   */
+  public void setSnapShotEnabledFlag(boolean isSnapShotEnabled) {
+if (isSnapShotEnabled) {
+  attr.add(AttrFlags.SNAPSHOT_ENABLED);
+} else {
+  attr.remove(AttrFlags.SNAPSHOT_ENABLED);
+}
+  }
+
+  /**
* @return The contents of the symbolic link.
*/
   public Path getSymlink() throws IOException {
@@ -486,4 +509,6 @@ public class FileStatus implements Writable, 
Comparable,
 }
   }
 
+
+
 }

http://git-wip-us.apache.org/repos/asf/hadoop/blob/107c1777/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
--
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
index aa7d8f5..23caf2e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/protocolPB/PBHelper.java
@@ -94,11 +94,15 @@ public final class PBHelper {
 owner = proto.getOwner();
 group = proto.getGroup();
 int flags = proto.getFlags();
-return new FileStatus(length, isdir, blockReplication, blocksize,
-mtime, atime, permission, owner, group, symlink, path,
-(flags & FileStatusProto.Flags.HAS_ACL_VALUE)   != 0,
+FileStatus fileStatus = new FileStatus(length, isdir, blockReplication,
+blocksize, mtime, atime, permission, owner, group, symlink, path,
+(flags & FileStatusProto.Flags.HAS_ACL_VALUE) != 0,
 (flags & FileStatusProto.Flags.HAS_CRYPT_VALUE) != 0,
-