本文整理了Java中org.apache.hadoop.mapred.Queue.isHierarchySameAs
方法的一些代码示例,展示了Queue.isHierarchySameAs
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.isHierarchySameAs
方法的具体详情如下:
包路径:org.apache.hadoop.mapred.Queue
类名称: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(
内容来源于网络,如有侵权,请联系作者删除!