diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/StaticStorageClassRegistry.java b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/StaticStorageClassRegistry.java index 926e4f8d3891..ae23df78ac9d 100644 --- a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/StaticStorageClassRegistry.java +++ b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/StaticStorageClassRegistry.java @@ -89,6 +89,26 @@ public String getName() { } }; + public static final StorageClass CLOSE_TWO = new StorageClass() { + + @Override + public OpenStateConfiguration getOpenStateConfiguration() { + return new OpenStateConfiguration( + HddsProtos.ReplicationType.RATIS, + HddsProtos.ReplicationFactor.THREE); + } + + @Override + public ClosedStateConfiguration getClosedStateConfiguration() { + return new ClosedStateConfiguration(2); + } + + @Override + public String getName() { + return "CLOSE_TWO"; + } + }; + private static final Map STRING_STORAGE_CLASS_MAP = new HashMap<>(); static { @@ -96,6 +116,7 @@ public String getName() { STRING_STORAGE_CLASS_MAP.put(REDUCED_REDUNDANCY.getName(), REDUCED_REDUNDANCY); STRING_STORAGE_CLASS_MAP.put(LEGACY.getName(), LEGACY); + STRING_STORAGE_CLASS_MAP.put(CLOSE_TWO.getName(), CLOSE_TWO); } @Override