|
@@ -18,6 +18,7 @@
|
|
package org.apache.hadoop.ozone.web.ozShell.bucket;
|
|
package org.apache.hadoop.ozone.web.ozShell.bucket;
|
|
|
|
|
|
import org.apache.hadoop.hdds.protocol.StorageType;
|
|
import org.apache.hadoop.hdds.protocol.StorageType;
|
|
|
|
+import org.apache.hadoop.ozone.OzoneConsts;
|
|
import org.apache.hadoop.ozone.client.BucketArgs;
|
|
import org.apache.hadoop.ozone.client.BucketArgs;
|
|
import org.apache.hadoop.ozone.client.OzoneBucket;
|
|
import org.apache.hadoop.ozone.client.OzoneBucket;
|
|
import org.apache.hadoop.ozone.client.OzoneClient;
|
|
import org.apache.hadoop.ozone.client.OzoneClient;
|
|
@@ -44,6 +45,11 @@ public class CreateBucketHandler extends Handler {
|
|
description = "bucket encryption key name")
|
|
description = "bucket encryption key name")
|
|
private String bekName;
|
|
private String bekName;
|
|
|
|
|
|
|
|
+ @Option(names = {"--enforcegdpr", "-g"},
|
|
|
|
+ description = "if true, indicates GDPR enforced bucket, " +
|
|
|
|
+ "false/unspecified indicates otherwise")
|
|
|
|
+ private Boolean isGdprEnforced;
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* Executes create bucket.
|
|
* Executes create bucket.
|
|
*/
|
|
*/
|
|
@@ -61,6 +67,14 @@ public class CreateBucketHandler extends Handler {
|
|
.setStorageType(StorageType.DEFAULT)
|
|
.setStorageType(StorageType.DEFAULT)
|
|
.setVersioning(false);
|
|
.setVersioning(false);
|
|
|
|
|
|
|
|
+ if(isGdprEnforced != null) {
|
|
|
|
+ if(isGdprEnforced) {
|
|
|
|
+ bb.addMetadata(OzoneConsts.GDPR_FLAG, String.valueOf(Boolean.TRUE));
|
|
|
|
+ } else {
|
|
|
|
+ bb.addMetadata(OzoneConsts.GDPR_FLAG, String.valueOf(Boolean.FALSE));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
if (bekName != null) {
|
|
if (bekName != null) {
|
|
if (!bekName.isEmpty()) {
|
|
if (!bekName.isEmpty()) {
|
|
bb.setBucketEncryptionKey(bekName);
|
|
bb.setBucketEncryptionKey(bekName);
|