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

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

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

Queue.isHierarchySameAs介绍

[英]For each node validate if current node hierarchy is same newState. recursively check for child nodes.
[中]对于每个节点,验证当前节点层次结构是否为相同的newState。递归检查子节点。

代码示例

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

/**
 * @param originalQManager
 * @throws Exception
 */
private void testRefreshFailureWithChangeOfHierarchy(
  QueueManager originalQManager)
  throws Exception {
 // Make sure that isHierarchySame returns false.
 QueueManager modifiedQueueManager = new QueueManager();
 assertFalse("Hierarchy changed after refresh!",
   originalQManager.getRoot().isHierarchySameAs(
     modifiedQueueManager.getRoot()));
 // Refresh the QueueManager and make sure it fails.
 try {
  originalQManager.refreshQueues(null, null);
  fail("Queue-refresh should have failed!");
 } catch (Exception e) {
  // Refresh failed as expected. Check the error message.
  assertTrue(
    "Exception message should point to a change in queue hierarchy!",
    e.getMessage().contains(
      QueueManager.MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY));
 }
 // Make sure that the old configuration is retained.
 List<JobQueueInfo> rootQueues =
   originalQManager.getRoot().getJobQueueInfo().getChildren();
 assertTrue(rootQueues.size() == 1);
}

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

Queue q = itr1.next();
Queue newq = itr2.next();
if(! (q.isHierarchySameAs(newq)) ) {
 LOG.info(" Queue " + q.getName() + " not equal to " + newq.getName());
 return false;

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

Queue q = itr1.next();
Queue newq = itr2.next();
if(! (q.isHierarchySameAs(newq)) ) {
 LOG.info(" Queue " + q.getName() + " not equal to " + newq.getName());
 return false;

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

Queue q = itr1.next();
Queue newq = itr2.next();
if(! (q.isHierarchySameAs(newq)) ) {
 LOG.info(" Queue " + q.getName() + " not equal to " + newq.getName());
 return false;

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

Queue q = itr1.next();
Queue newq = itr2.next();
if(! (q.isHierarchySameAs(newq)) ) {
 LOG.info(" Queue " + q.getName() + " not equal to " + newq.getName());
 return false;

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

if (!root.isHierarchySameAs(cp.getRoot())) {
 LOG.warn(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);
 throw new IOException(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);

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

if (!root.isHierarchySameAs(cp.getRoot())) {
 LOG.warn(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);
 throw new IOException(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);

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

if (!root.isHierarchySameAs(cp.getRoot())) {
 LOG.warn(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);
 throw new IOException(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);

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

if (!root.isHierarchySameAs(cp.getRoot())) {
 LOG.warn(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);
 throw new IOException(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);

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

Queue q = itr1.next();
Queue newq = itr2.next();
if(! (q.isHierarchySameAs(newq)) ) {
 LOG.info(" Queue " + q.getName() + " not equal to " + newq.getName());
 return false;

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

if (!root.isHierarchySameAs(cp.getRoot())) {
 LOG.warn(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);
 throw new IOException(MSG_REFRESH_FAILURE_WITH_CHANGE_OF_HIERARCHY);

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

writeToFile(doc, QUEUES_CONFIG_FILE_PATH);
QueueConfigurationParser cp = new QueueConfigurationParser(QUEUES_CONFIG_FILE_PATH, true);
qm.getRoot().isHierarchySameAs(cp.getRoot());
qm.setQueues(
 cp.getRoot().getChildren().toArray(

相关文章