Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11251-LoadTestTool should grant READ permission for the users that 

are given READ access for specific cells (Ram)
This commit is contained in:
Ramkrishna 2014-05-26 11:47:04 +05:30
parent de1f96096a
commit 1ce333901e
1 changed files with 24 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
hbase-server/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java
View File

@ -517,19 +517,38 @@ public class LoadTestTool extends AbstractHBaseTool {
if (userOwner != null) { if (userOwner != null) {
LOG.info("Granting permission for the user " + userOwner.getShortName()); LOG.info("Granting permission for the user " + userOwner.getShortName());
AccessControlProtos.Permission.Action[] actions = { AccessControlProtos.Permission.Action[] actions = {
AccessControlProtos.Permission.Action.ADMIN, AccessControlProtos.Permission.Action.ADMIN, AccessControlProtos.Permission.Action.CREATE,
AccessControlProtos.Permission.Action.CREATE, AccessControlProtos.Permission.Action.READ, AccessControlProtos.Permission.Action.READ, AccessControlProtos.Permission.Action.WRITE };
AccessControlProtos.Permission.Action.WRITE };
try { try {
AccessControlClient.grant(conf, tableName, userOwner.getShortName(), COLUMN_FAMILY, AccessControlClient.grant(conf, tableName, userOwner.getShortName(), null, null, actions);
null, actions);
} catch (Throwable e) { } catch (Throwable e) {
LOG.fatal("Error in granting permission for the user " + userOwner.getShortName(), e); LOG.fatal("Error in granting permission for the user " + userOwner.getShortName(), e);
return EXIT_FAILURE; 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 (isWrite) {
if (userOwner != null) { if (userOwner != null) {
writerThreads = new MultiThreadedWriterWithACL(dataGen, conf, tableName, userOwner); writerThreads = new MultiThreadedWriterWithACL(dataGen, conf, tableName, userOwner);