You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by el...@apache.org on 2021/03/29 08:23:07 UTC
[ozone] branch HDDS-3816-ec updated: HDDS-5003. Introduce EC
replication type (#2064)
This is an automated email from the ASF dual-hosted git repository.
elek pushed a commit to branch HDDS-3816-ec
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/HDDS-3816-ec by this push:
new cec9105 HDDS-5003. Introduce EC replication type (#2064)
cec9105 is described below
commit cec910568cba20ae16b460b5ca85edda05d13d55
Author: Elek, Márton <el...@users.noreply.github.com>
AuthorDate: Mon Mar 29 10:22:49 2021 +0200
HDDS-5003. Introduce EC replication type (#2064)
---
.../main/java/org/apache/hadoop/hdds/scm/XceiverClientManager.java | 3 +++
.../src/main/java/org/apache/hadoop/hdds/client/ReplicationType.java | 5 ++++-
hadoop-hdds/interface-client/src/main/proto/hdds.proto | 1 +
.../main/java/org/apache/hadoop/ozone/shell/keys/PutKeyHandler.java | 2 +-
4 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientManager.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientManager.java
index 31728c6..971e9e7 100644
--- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientManager.java
+++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientManager.java
@@ -237,6 +237,9 @@ public class XceiverClientManager implements Closeable, XceiverClientFactory {
case STAND_ALONE:
client = new XceiverClientGrpc(pipeline, conf, caCert);
break;
+ case EC:
+ client = new XceiverClientGrpc(pipeline, conf, caCert);
+ break;
case CHAINED:
default:
throw new IOException("not implemented" + pipeline.getType());
diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/client/ReplicationType.java b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/client/ReplicationType.java
index 11a8218..83f04bb 100644
--- a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/client/ReplicationType.java
+++ b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/client/ReplicationType.java
@@ -26,7 +26,8 @@ import org.apache.hadoop.hdds.protocol.proto.HddsProtos;
public enum ReplicationType {
RATIS,
STAND_ALONE,
- CHAINED;
+ CHAINED,
+ EC;
public static ReplicationType fromProto(
HddsProtos.ReplicationType replicationType) {
@@ -40,6 +41,8 @@ public enum ReplicationType {
return ReplicationType.STAND_ALONE;
case CHAINED:
return ReplicationType.CHAINED;
+ case EC:
+ return ReplicationType.EC;
default:
throw new IllegalArgumentException(
"Unsupported ProtoBuf replication type: " + replicationType);
diff --git a/hadoop-hdds/interface-client/src/main/proto/hdds.proto b/hadoop-hdds/interface-client/src/main/proto/hdds.proto
index 79012ee..0547044 100644
--- a/hadoop-hdds/interface-client/src/main/proto/hdds.proto
+++ b/hadoop-hdds/interface-client/src/main/proto/hdds.proto
@@ -250,6 +250,7 @@ enum ReplicationType {
RATIS = 1;
STAND_ALONE = 2;
CHAINED = 3;
+ EC = 4;
}
enum ReplicationFactor {
diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/shell/keys/PutKeyHandler.java b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/shell/keys/PutKeyHandler.java
index c01e22c..866d4c6 100644
--- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/shell/keys/PutKeyHandler.java
+++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/shell/keys/PutKeyHandler.java
@@ -65,7 +65,7 @@ public class PutKeyHandler extends KeyHandler {
@Option(names = {"-t", "--type"},
description = "Replication type of the new key. (use RATIS or " +
- "STAND_ALONE) Default is specified in the cluster-wide config.")
+ "STAND_ALONE or EC) Default is specified in the cluster-wide config.")
private ReplicationType replicationType;
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org