org.apache.hadoop.mapred.Queue.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(147)

本文整理了Java中org.apache.hadoop.mapred.Queue.<init>方法的一些代码示例,展示了Queue.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.<init>方法的具体详情如下:
包路径:org.apache.hadoop.mapred.Queue
类名称:Queue
方法名:<init>

Queue.<init>介绍

[英]Default constructor is useful in creating the hierarchy. The variables are populated using mutator methods.
[中]默认构造函数在创建层次结构时很有用。使用mutator方法填充变量。

代码示例

代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core

private List<Queue> createQueues(Configuration conf) {
 String[] queueNameValues = conf.getStrings(
  MAPRED_QUEUE_NAMES_KEY);
 List<Queue> list = new ArrayList<Queue>();
 for (String name : queueNameValues) {
  try {
   Map<String, AccessControlList> acls = getQueueAcls(
    name, conf);
   QueueState state = getQueueState(name, conf);
   Queue q = new Queue(name, acls, state);
   list.add(q);
  } catch (Throwable t) {
   LOG.warn("Not able to initialize queue " + name);
  }
 }
 return list;
}

代码示例来源:origin: io.hops/hadoop-mapreduce-client-core

private List<Queue> createQueues(Configuration conf) {
 String[] queueNameValues = conf.getStrings(
  MAPRED_QUEUE_NAMES_KEY);
 List<Queue> list = new ArrayList<Queue>();
 for (String name : queueNameValues) {
  try {
   Map<String, AccessControlList> acls = getQueueAcls(
    name, conf);
   QueueState state = getQueueState(name, conf);
   Queue q = new Queue(name, acls, state);
   list.add(q);
  } catch (Throwable t) {
   LOG.warn("Not able to initialize queue " + name);
  }
 }
 return list;
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

private List<Queue> createQueues(Configuration conf) {
 String[] queueNameValues = conf.getStrings(
  MAPRED_QUEUE_NAMES_KEY);
 List<Queue> list = new ArrayList<Queue>();
 for (String name : queueNameValues) {
  try {
   Map<String, AccessControlList> acls = getQueueAcls(
    name, conf);
   QueueState state = getQueueState(name, conf);
   Queue q = new Queue(name, acls, state);
   list.add(q);
  } catch (Throwable t) {
   LOG.warn("Not able to initialize queue " + name);
  }
 }
 return list;
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapred

private List<Queue> createQueues(Configuration conf) {
 String[] queueNameValues = conf.getStrings(
  MAPRED_QUEUE_NAMES_KEY);
 List<Queue> list = new ArrayList<Queue>();
 for (String name : queueNameValues) {
  try {
   Map<String, AccessControlList> acls = getQueueAcls(
    name, conf);
   QueueState state = getQueueState(name, conf);
   Queue q = new Queue(name, acls, state);
   list.add(q);
  } catch (Throwable t) {
   LOG.warn("Not able to initialize queue " + name);
  }
 }
 return list;
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

private List<Queue> createQueues(Configuration conf) {
 String[] queueNameValues = conf.getStrings(
  MAPRED_QUEUE_NAMES_KEY);
 List<Queue> list = new ArrayList<Queue>();
 for (String name : queueNameValues) {
  try {
   Map<String, AccessControlList> acls = getQueueAcls(
    name, conf);
   QueueState state = getQueueState(name, conf);
   Queue q = new Queue(name, acls, state);
   list.add(q);
  } catch (Throwable t) {
   LOG.warn("Not able to initialize queue " + name);
  }
 }
 return list;
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

rootNode = new Queue();
rootNode.setName("");

代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core

rootNode = new Queue();
rootNode.setName("");

代码示例来源:origin: org.apache.hadoop/hadoop-mapred

rootNode = new Queue();
rootNode.setName("");

代码示例来源:origin: io.hops/hadoop-mapreduce-client-core

rootNode = new Queue();
rootNode.setName("");

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

DeprecatedQueueConfigurationParser(Configuration conf) {
 //If not configuration done return immediately.
 if(!deprecatedConf(conf)) {
  return;
 }
 List<Queue> listq = createQueues(conf);
 this.setAclsEnabled(conf.getBoolean(MRConfig.MR_ACLS_ENABLED, false));
 root = new Queue();
 root.setName("");
 for (Queue q : listq) {
  root.addChild(q);
 }
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

DeprecatedQueueConfigurationParser(Configuration conf) {
 //If not configuration done return immediately.
 if(!deprecatedConf(conf)) {
  return;
 }
 List<Queue> listq = createQueues(conf);
 this.setAclsEnabled(conf.getBoolean(MRConfig.MR_ACLS_ENABLED, false));
 root = new Queue();
 root.setName("");
 for (Queue q : listq) {
  root.addChild(q);
 }
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

rootNode = new Queue();
rootNode.setName("");

代码示例来源:origin: io.hops/hadoop-mapreduce-client-core

DeprecatedQueueConfigurationParser(Configuration conf) {
 //If not configuration done return immediately.
 if(!deprecatedConf(conf)) {
  return;
 }
 List<Queue> listq = createQueues(conf);
 this.setAclsEnabled(conf.getBoolean(MRConfig.MR_ACLS_ENABLED, false));
 root = new Queue();
 root.setName("");
 for (Queue q : listq) {
  root.addChild(q);
 }
}

代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core

DeprecatedQueueConfigurationParser(Configuration conf) {
 //If not configuration done return immediately.
 if(!deprecatedConf(conf)) {
  return;
 }
 List<Queue> listq = createQueues(conf);
 this.setAclsEnabled(conf.getBoolean(MRConfig.MR_ACLS_ENABLED, false));
 root = new Queue();
 root.setName("");
 for (Queue q : listq) {
  root.addChild(q);
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapred

DeprecatedQueueConfigurationParser(Configuration conf) {
 //If not configuration done return immediately.
 if(!deprecatedConf(conf)) {
  return;
 }
 List<Queue> listq = createQueues(conf);
 this.setAclsEnabled(conf.getBoolean(MRConfig.MR_ACLS_ENABLED, false));
 root = new Queue();
 root.setName("");
 for (Queue q : listq) {
  root.addChild(q);
 }
}

代码示例来源:origin: io.hops/hadoop-mapreduce-client-core

Queue newQueue = new Queue();
Map<String, AccessControlList> acls =
 new HashMap<String, AccessControlList>();

代码示例来源:origin: ch.cern.hadoop/hadoop-mapreduce-client-core

Queue newQueue = new Queue();
Map<String, AccessControlList> acls =
 new HashMap<String, AccessControlList>();

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

Queue newQueue = new Queue();
Map<String, AccessControlList> acls =
 new HashMap<String, AccessControlList>();

代码示例来源:origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

Queue newQueue = new Queue();
Map<String, AccessControlList> acls =
 new HashMap<String, AccessControlList>();

代码示例来源:origin: org.apache.hadoop/hadoop-mapred

Queue newQueue = new Queue();
Map<String, AccessControlList> acls =
 new HashMap<String, AccessControlList>();

相关文章