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 vi...@apache.org on 2015/06/02 13:09:03 UTC
hadoop git commit: HDFS-8336. Expose some administrative erasure
coding operations to HdfsAdmin (Contributed by Uma Maheswara Rao G)
Repository: hadoop
Updated Branches:
refs/heads/HDFS-7285 0799e1e4b -> 9b54e66f3
HDFS-8336. Expose some administrative erasure coding operations to HdfsAdmin (Contributed by Uma Maheswara Rao G)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/9b54e66f
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/9b54e66f
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/9b54e66f
Branch: refs/heads/HDFS-7285
Commit: 9b54e66f3ea6a5a6945d18ba534cfb4f2419facb
Parents: 0799e1e
Author: Vinayakumar B <vi...@apache.org>
Authored: Tue Jun 2 16:38:43 2015 +0530
Committer: Vinayakumar B <vi...@apache.org>
Committed: Tue Jun 2 16:38:43 2015 +0530
----------------------------------------------------------------------
.../hadoop-hdfs/CHANGES-HDFS-EC-7285.txt | 3 ++
.../apache/hadoop/hdfs/client/HdfsAdmin.java | 40 ++++++++++++++++++++
2 files changed, 43 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/9b54e66f/hadoop-hdfs-project/hadoop-hdfs/CHANGES-HDFS-EC-7285.txt
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES-HDFS-EC-7285.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES-HDFS-EC-7285.txt
index 01d8cf0..e7335b2 100755
--- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES-HDFS-EC-7285.txt
+++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES-HDFS-EC-7285.txt
@@ -265,3 +265,6 @@
HDFS-8481. Erasure coding: remove workarounds in client side stripped blocks
recovering. (zhz)
+
+ HDFS-8336. Expose some administrative erasure coding operations to HdfsAdmin
+ (Uma Maheswara Rao G via vinayakumarb)
http://git-wip-us.apache.org/repos/asf/hadoop/blob/9b54e66f/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/client/HdfsAdmin.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/client/HdfsAdmin.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/client/HdfsAdmin.java
index 84499bb..5a3c885 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/client/HdfsAdmin.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/client/HdfsAdmin.java
@@ -37,9 +37,11 @@ import org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo;
import org.apache.hadoop.hdfs.protocol.CachePoolEntry;
import org.apache.hadoop.hdfs.protocol.CachePoolInfo;
import org.apache.hadoop.hdfs.protocol.EncryptionZone;
+import org.apache.hadoop.hdfs.protocol.ErasureCodingZone;
import org.apache.hadoop.hdfs.protocol.HdfsConstants;
import org.apache.hadoop.security.AccessControlException;
import org.apache.hadoop.hdfs.tools.DFSAdmin;
+import org.apache.hadoop.io.erasurecode.ECSchema;
/**
* The public API for performing administrative functions on HDFS. Those writing
@@ -363,4 +365,42 @@ public class HdfsAdmin {
throws IOException {
dfs.setStoragePolicy(src, policyName);
}
+
+ /**
+ * Create the ErasureCoding zone
+ *
+ * @param path
+ * Directory to create the ErasureCoding zone
+ * @param schema
+ * ECSchema for the zone. If not specified default will be used.
+ * @param cellSize
+ * Cellsize for the striped ErasureCoding
+ * @throws IOException
+ */
+ public void createErasureCodingZone(final Path path, final ECSchema schema,
+ final int cellSize) throws IOException {
+ dfs.createErasureCodingZone(path, schema, cellSize);
+ }
+
+ /**
+ * Get the ErasureCoding zone information for the specified path
+ *
+ * @param path
+ * @return Returns the zone information if path is in EC zone, null otherwise
+ * @throws IOException
+ */
+ public ErasureCodingZone getErasureCodingZone(final Path path)
+ throws IOException {
+ return dfs.getErasureCodingZone(path);
+ }
+
+ /**
+ * Get the ErasureCoding schemas supported.
+ *
+ * @return ECSchemas
+ * @throws IOException
+ */
+ public ECSchema[] getECSchemas() throws IOException {
+ return dfs.getClient().getECSchemas();
+ }
}