本文整理了Java中org.apache.hadoop.mapred.QueueManager.addToSet
方法的一些代码示例,展示了QueueManager.addToSet
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueueManager.addToSet
方法的具体详情如下:
包路径:org.apache.hadoop.mapred.QueueManager
类名称:QueueManager
方法名:addToSet
暂无
代码示例来源:origin: com.facebook.hadoop/hadoop-core
private void initialize(Configuration conf) {
aclsEnabled = conf.getBoolean("mapred.acls.enabled", false);
String[] queues = conf.getStrings("mapred.queue.names",
new String[] {JobConf.DEFAULT_QUEUE_NAME});
addToSet(queueNames, queues);
aclsMap = getQueueAcls(conf);
}
代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core
private void initialize(Configuration conf) {
aclsEnabled = conf.getBoolean("mapred.acls.enabled", false);
String[] queues = conf.getStrings("mapred.queue.names",
new String[] {JobConf.DEFAULT_QUEUE_NAME});
addToSet(queueNames, queues);
// for every queue, and every operation, get the ACL
// if any is specified and store in aclsMap.
for (String queue : queues) {
for (QueueOperation oper : QueueOperation.values()) {
String key = toFullPropertyName(queue, oper.getAclName());
String aclString = conf.get(key, "*");
aclsMap.put(key, new ACL(aclString));
}
}
}
内容来源于网络,如有侵权,请联系作者删除!