本文整理了Java中org.apache.hadoop.mapred.QueueACL
类的一些代码示例,展示了QueueACL
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueueACL
类的具体详情如下:
包路径:org.apache.hadoop.mapred.QueueACL
类名称:QueueACL
[英]Enum representing an AccessControlList that drives set of operations that can be performed on a queue.
[中]
代码示例来源:origin: io.prestosql.hadoop/hadoop-apache
/**
* Parse ACLs for the queue from the configuration.
*/
private Map<String, AccessControlList> getQueueAcls(
String name,
Configuration conf) {
HashMap<String, AccessControlList> map =
new HashMap<String, AccessControlList>();
for (QueueACL qAcl : QueueACL.values()) {
String aclKey = toFullPropertyName(name, qAcl.getAclName());
map.put(
aclKey, new AccessControlList(
conf.get(
aclKey, "*")));
}
return map;
}
}
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
/**
* Returns the specific queue ACL for the given queue.
* Returns null if the given queue does not exist or the acl is not
* configured for that queue.
* If acls are disabled(mapreduce.cluster.acls.enabled set to false), returns
* ACL with all users.
*/
synchronized AccessControlList getQueueACL(String queueName,
QueueACL qACL) {
if (areAclsEnabled) {
Queue q = leafQueues.get(queueName);
if (q != null) {
return q.getAcls().get(toFullPropertyName(
queueName, qACL.getAclName()));
}
else {
LOG.warn("Queue " + queueName + " is not present.");
return null;
}
}
return new AccessControlList("*");
}
代码示例来源:origin: org.apache.hadoop/hadoop-mapred-test
protected void validateJobACLsFileContent() {
JobConf jobACLsConf = TaskLogServlet.getConfFromJobACLsFile(jobId);
assertTrue(jobACLsConf.get("user.name").equals(
localizedJobConf.getUser()));
assertTrue(jobACLsConf.get(MRJobConfig.JOB_ACL_VIEW_JOB).
equals(localizedJobConf.get(MRJobConfig.JOB_ACL_VIEW_JOB)));
String queue = localizedJobConf.getQueueName();
assertTrue(queue.equalsIgnoreCase(jobACLsConf.getQueueName()));
String qACLName = toFullPropertyName(queue,
QueueACL.ADMINISTER_JOBS.getAclName());
assertTrue(jobACLsConf.get(qACLName).equals(
localizedJobConf.get(qACLName)));
}
代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core
/**
* Parse ACLs for the queue from the configuration.
*/
private Map<String, AccessControlList> getQueueAcls(
String name,
Configuration conf) {
HashMap<String, AccessControlList> map =
new HashMap<String, AccessControlList>();
for (QueueACL qAcl : QueueACL.values()) {
String aclKey = toFullPropertyName(name, qAcl.getAclName());
map.put(
aclKey, new AccessControlList(
conf.get(
aclKey, "*")));
}
return map;
}
}
代码示例来源:origin: io.hops/hadoop-mapreduce-client-core
qACL.getAclName()) + " for user " + ugi.getShortUserName());
toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
return false;
代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core
/**
* Parse ACLs for the queue from the configuration.
*/
private Map<String, AccessControlList> getQueueAcls(
String name,
Configuration conf) {
HashMap<String, AccessControlList> map =
new HashMap<String, AccessControlList>();
for (QueueACL qAcl : QueueACL.values()) {
String aclKey = toFullPropertyName(name, qAcl.getAclName());
map.put(
aclKey, new AccessControlList(
conf.get(
aclKey, "*")));
}
return map;
}
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core
qACL.getAclName()) + " for user " + ugi.getShortUserName());
toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
return false;
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
/**
* Parse ACLs for the queue from the configuration.
*/
private Map<String, AccessControlList> getQueueAcls(
String name,
Configuration conf) {
HashMap<String, AccessControlList> map =
new HashMap<String, AccessControlList>();
for (QueueACL qAcl : QueueACL.values()) {
String aclKey = toFullPropertyName(name, qAcl.getAclName());
map.put(
aclKey, new AccessControlList(
conf.get(
aclKey, "*")));
}
return map;
}
}
代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core
qACL.getAclName()) + " for user " + ugi.getShortUserName());
toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
return false;
代码示例来源:origin: io.hops/hadoop-mapreduce-client-core
/**
* Parse ACLs for the queue from the configuration.
*/
private Map<String, AccessControlList> getQueueAcls(
String name,
Configuration conf) {
HashMap<String, AccessControlList> map =
new HashMap<String, AccessControlList>();
for (QueueACL qAcl : QueueACL.values()) {
String aclKey = toFullPropertyName(name, qAcl.getAclName());
map.put(
aclKey, new AccessControlList(
conf.get(
aclKey, "*")));
}
return map;
}
}
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
QueueACL.ADMINISTER_JOBS.getAclName());
String queueAdminsACL = conf.get(qACLName, " ");
aclConf.set(qACLName, queueAdminsACL);
代码示例来源:origin: io.prestosql.hadoop/hadoop-apache
QueueACL[] qAcls = QueueACL.values();
for (String queueName : leafQueues.keySet()) {
QueueAclsInfo queueAclsInfo = null;
operationsAllowed = new ArrayList<String>();
operationsAllowed.add(qAcl.getAclName());
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
qACL.getAclName()) + " for user " + ugi.getShortUserName());
toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
return false;
代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core
for (QueueACL qAcl : QueueACL.values()) {
String key = toFullPropertyName(queue, qAcl.getAclName());
String aclString = conf.get(key);
if (aclString != null) {
代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core
newQueue.setName(name);
submitKey = toFullPropertyName(name,
QueueACL.SUBMIT_JOB.getAclName());
adminKey = toFullPropertyName(name,
QueueACL.ADMINISTER_JOBS.getAclName());
代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core
for (QueueACL qAcl : QueueACL.values()) {
String key = toFullPropertyName(queue, qAcl.getAclName());
String aclString = conf.get(key);
if (aclString != null) {
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
newQueue.setName(name);
submitKey = toFullPropertyName(name,
QueueACL.SUBMIT_JOB.getAclName());
adminKey = toFullPropertyName(name,
QueueACL.ADMINISTER_JOBS.getAclName());
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
for (QueueACL qAcl : QueueACL.values()) {
String key = toFullPropertyName(queue, qAcl.getAclName());
String aclString = conf.get(key);
if (aclString != null) {
代码示例来源:origin: io.hops/hadoop-mapreduce-client-core
newQueue.setName(name);
submitKey = toFullPropertyName(name,
QueueACL.SUBMIT_JOB.getAclName());
adminKey = toFullPropertyName(name,
QueueACL.ADMINISTER_JOBS.getAclName());
代码示例来源:origin: io.hops/hadoop-mapreduce-client-core
QueueACL[] qAcls = QueueACL.values();
for (String queueName : leafQueues.keySet()) {
QueueAclsInfo queueAclsInfo = null;
operationsAllowed = new ArrayList<String>();
operationsAllowed.add(qAcl.getAclName());
内容来源于网络,如有侵权,请联系作者删除!