diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java index 34ad50f8a7e..f9b847c1216 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java @@ -432,10 +432,12 @@ static ContentSummary toContentSummary(final Map json) { final long length = ((Number) m.get("length")).longValue(); final long fileCount = ((Number) m.get("fileCount")).longValue(); final long directoryCount = ((Number) m.get("directoryCount")).longValue(); + final String ecPolicy = ((String) m.get("ecPolicy")); ContentSummary.Builder builder = new ContentSummary.Builder() .length(length) .fileCount(fileCount) - .directoryCount(directoryCount); + .directoryCount(directoryCount) + .erasureCodingPolicy(ecPolicy); builder = buildQuotaUsage(builder, m, ContentSummary.Builder.class); return builder.build(); } diff --git a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/client/HttpFSFileSystem.java b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/client/HttpFSFileSystem.java index 1efafe74f0a..ac909ddba75 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/client/HttpFSFileSystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/client/HttpFSFileSystem.java @@ -193,6 +193,7 @@ public static FILE_TYPE getType(FileStatus fileStatus) { public static final String CONTENT_SUMMARY_JSON = "ContentSummary"; public static final String CONTENT_SUMMARY_DIRECTORY_COUNT_JSON = "directoryCount"; + public static final String CONTENT_SUMMARY_ECPOLICY_JSON = "ecPolicy"; public static final String CONTENT_SUMMARY_FILE_COUNT_JSON = "fileCount"; public static final String CONTENT_SUMMARY_LENGTH_JSON = "length"; @@ -1140,7 +1141,8 @@ public ContentSummary getContentSummary(Path f) throws IOException { ContentSummary.Builder builder = new ContentSummary.Builder() .length((Long) json.get(CONTENT_SUMMARY_LENGTH_JSON)) .fileCount((Long) json.get(CONTENT_SUMMARY_FILE_COUNT_JSON)) - .directoryCount((Long) json.get(CONTENT_SUMMARY_DIRECTORY_COUNT_JSON)); + .directoryCount((Long) json.get(CONTENT_SUMMARY_DIRECTORY_COUNT_JSON)) + .erasureCodingPolicy((String) json.get(CONTENT_SUMMARY_ECPOLICY_JSON)); builder = buildQuotaUsage(builder, json, ContentSummary.Builder.class); return builder.build(); } diff --git a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/server/FSOperations.java b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/server/FSOperations.java index 3f792560b21..043f3e1a6a6 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/server/FSOperations.java +++ b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/main/java/org/apache/hadoop/fs/http/server/FSOperations.java @@ -265,6 +265,8 @@ private static Map contentSummaryToJSON(ContentSummary contentSummary) { Map json = new LinkedHashMap(); json.put(HttpFSFileSystem.CONTENT_SUMMARY_DIRECTORY_COUNT_JSON, contentSummary.getDirectoryCount()); + json.put(HttpFSFileSystem.CONTENT_SUMMARY_ECPOLICY_JSON, + contentSummary.getErasureCodingPolicy()); json.put(HttpFSFileSystem.CONTENT_SUMMARY_FILE_COUNT_JSON, contentSummary.getFileCount()); json.put(HttpFSFileSystem.CONTENT_SUMMARY_LENGTH_JSON, diff --git a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/test/java/org/apache/hadoop/fs/http/client/BaseTestHttpFSWith.java b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/test/java/org/apache/hadoop/fs/http/client/BaseTestHttpFSWith.java index d8e1379f7b0..08cdb1249e8 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/test/java/org/apache/hadoop/fs/http/client/BaseTestHttpFSWith.java +++ b/hadoop-hdfs-project/hadoop-hdfs-httpfs/src/test/java/org/apache/hadoop/fs/http/client/BaseTestHttpFSWith.java @@ -682,6 +682,8 @@ private void testContentSummary() throws Exception { fs.close(); assertEquals(hdfsContentSummary.getDirectoryCount(), httpContentSummary.getDirectoryCount()); + assertEquals(hdfsContentSummary.getErasureCodingPolicy(), + httpContentSummary.getErasureCodingPolicy()); assertEquals(hdfsContentSummary.getFileCount(), httpContentSummary.getFileCount()); assertEquals(hdfsContentSummary.getLength(),