hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ramkris...@apache.org
Subject git commit: HBASE-11251-LoadTestTool should grant READ permission for the users that are given READ access for specific cells (Ram)
Date Mon, 26 May 2014 06:17:46 GMT
Repository: hbase
Updated Branches:
  refs/heads/master de1f96096 -> 1ce333901


HBASE-11251-LoadTestTool should grant READ permission for the users that
are given READ access for specific cells (Ram)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1ce33390
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1ce33390
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1ce33390

Branch: refs/heads/master
Commit: 1ce333901e6ed614c82a21d306dc8310c8fe491b
Parents: de1f960
Author: Ramkrishna <ramkrishna.s.vasudevan@intel.com>
Authored: Mon May 26 11:47:04 2014 +0530
Committer: Ramkrishna <ramkrishna.s.vasudevan@intel.com>
Committed: Mon May 26 11:47:04 2014 +0530

----------------------------------------------------------------------
 .../apache/hadoop/hbase/util/LoadTestTool.java  | 29 ++++++++++++++++----
 1 file changed, 24 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/1ce33390/hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java
index dd32f3b..bb607a9 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java
@@ -517,19 +517,38 @@ public class LoadTestTool extends AbstractHBaseTool {
     if (userOwner != null) {
       LOG.info("Granting permission for the user " + userOwner.getShortName());
       AccessControlProtos.Permission.Action[] actions = {
-          AccessControlProtos.Permission.Action.ADMIN,
-          AccessControlProtos.Permission.Action.CREATE, AccessControlProtos.Permission.Action.READ,
-          AccessControlProtos.Permission.Action.WRITE };
+        AccessControlProtos.Permission.Action.ADMIN, AccessControlProtos.Permission.Action.CREATE,
+        AccessControlProtos.Permission.Action.READ, AccessControlProtos.Permission.Action.WRITE
};
 
       try {
-        AccessControlClient.grant(conf, tableName, userOwner.getShortName(), COLUMN_FAMILY,
-            null, actions);
+        AccessControlClient.grant(conf, tableName, userOwner.getShortName(), null, null,
actions);
       } catch (Throwable e) {
         LOG.fatal("Error in granting permission for the user " + userOwner.getShortName(),
e);
         return EXIT_FAILURE;
       }
     }
 
+    if (userNames != null) {
+      // This will be comma separated list of expressions.
+      String users[] = userNames.split(",");
+      User user = null;
+      for (String userStr : users) {
+        if (isSecure(conf)) {
+          user = User.create(loginAndReturnUGI(conf, userStr));
+        } else {
+          user = User.createUserForTesting(conf, userStr, new String[0]);
+        }
+        LOG.info("Granting permission for the user " + user.getShortName());
+        AccessControlProtos.Permission.Action[] actions = { AccessControlProtos.Permission.Action.READ
};
+        try {
+          AccessControlClient.grant(conf, tableName, user.getShortName(), null, null, actions);
+        } catch (Throwable e) {
+          LOG.fatal("Error in granting permission for the user " + user.getShortName(), e);
+          return EXIT_FAILURE;
+        }
+      }
+    }
+
     if (isWrite) {
       if (userOwner != null) {
         writerThreads = new MultiThreadedWriterWithACL(dataGen, conf, tableName, userOwner);


Mime
View raw message