Java ResponseInfo类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.yarn.webapp.ResponseInfo类的典型用法代码示例。如果您正苦于以下问题：Java ResponseInfo类的具体用法？Java ResponseInfo怎么用？Java ResponseInfo使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ResponseInfo类属于org.apache.hadoop.yarn.webapp包，在下文中一共展示了ResponseInfo类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  ResponseInfo ri = info("\'" + qinfo.getQueueName() + "\' Queue Status").
      _("Used Resources:", qinfo.getUsedResources().toString()).
      _("Num Active Applications:", qinfo.getNumActiveApplications()).
      _("Num Pending Applications:", qinfo.getNumPendingApplications()).
      _("Min Resources:", qinfo.getMinResources().toString()).
      _("Max Resources:", qinfo.getMaxResources().toString());
  int maxApps = qinfo.getMaxApplications();
  if (maxApps < Integer.MAX_VALUE) {
      ri._("Max Running Applications:", qinfo.getMaxApplications());
  }
  ri._(STEADY_FAIR_SHARE + ":", qinfo.getSteadyFairShare().toString());
  ri._(INSTANTANEOUS_FAIR_SHARE + ":", qinfo.getFairShare().toString());
  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:naver，项目名称:hadoop，代码行数:20，代码来源:FairSchedulerPage.java

示例2: renderLeafQueueInfoWithPartition

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderLeafQueueInfoWithPartition(Block html) {
  nodeLabel = nodeLabel.length() == 0 ? "<DEFAULT_PARTITION>" : nodeLabel;
  // first display the queue's label specific details :
  ResponseInfo ri =
      info("\'" + lqinfo.getQueuePath().substring(5)
          + "\' Queue Status for Partition \'" + nodeLabel + "\'");
  renderQueueCapacityInfo(ri);
  html._(InfoBlock.class);
  // clear the info contents so this queue's info doesn't accumulate into
  // another queue's info
  ri.clear();

  // second display the queue specific details :
  ri =
      info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status")
          ._("Queue State:", lqinfo.getQueueState());
  renderCommonLeafQueueInfo(ri);

  
  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into
  // another queue's info
  ri.clear();
}

开发者ID:naver，项目名称:hadoop，代码行数:26，代码来源:CapacitySchedulerPage.java

示例3: renderCommonLeafQueueInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderCommonLeafQueueInfo(ResponseInfo ri) {
  ri.
  _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
  _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
  _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
  _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
  _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
  _("Max Application Master Resources:", lqinfo.getAMResourceLimit().toString()).
  _("Used Application Master Resources:", lqinfo.getUsedAMResource().toString()).
  _("Max Application Master Resources Per User:", lqinfo.getUserAMResourceLimit().toString()).
  _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
  _("Configured User Limit Factor:", StringUtils.format(
      "%.1f", lqinfo.getUserLimitFactor())).
  _("Accessible Node Labels:", StringUtils.join(",", lqinfo.getNodeLabels())).
  _("Preemption:", lqinfo.getPreemptionDisabled() ? "disabled" : "enabled");
}

开发者ID:naver，项目名称:hadoop，代码行数:17，代码来源:CapacitySchedulerPage.java

示例4: testInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
/**
 * Test the method 'info'.
 */
@Test
public void testInfo() {

  appController.info();
  Iterator<ResponseInfo.Item> iterator = appController.getResponseInfo()
      .iterator();
  ResponseInfo.Item item = iterator.next();
  assertEquals("Application ID:", item.key);
  assertEquals("application_0_0000", item.value);
  item = iterator.next();
  assertEquals("Application Name:", item.key);
  assertEquals("AppName", item.value);
  item = iterator.next();
  assertEquals("User:", item.key);
  assertEquals("User", item.value);

  item = iterator.next();
  assertEquals("Started on:", item.key);
  item = iterator.next();
  assertEquals("Elasped: ", item.key);

}

开发者ID:naver，项目名称:hadoop，代码行数:26，代码来源:TestAppController.java

示例5: renderLeafQueueInfoWithPartition

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderLeafQueueInfoWithPartition(Block html) {
  String nodeLabelDisplay = nodeLabel.length() == 0
      ? NodeLabel.DEFAULT_NODE_LABEL_PARTITION : nodeLabel;
  // first display the queue's label specific details :
  ResponseInfo ri =
      info("\'" + lqinfo.getQueuePath().substring(5)
          + "\' Queue Status for Partition \'" + nodeLabelDisplay + "\'");
  renderQueueCapacityInfo(ri, nodeLabel);
  html._(InfoBlock.class);
  // clear the info contents so this queue's info doesn't accumulate into
  // another queue's info
  ri.clear();

  // second display the queue specific details :
  ri =
      info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status")
          ._("Queue State:", lqinfo.getQueueState());
  renderCommonLeafQueueInfo(ri);

  html._(InfoBlock.class);
  // clear the info contents so this queue's info doesn't accumulate into
  // another queue's info
  ri.clear();
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:25，代码来源:CapacitySchedulerPage.java

示例6: renderCommonLeafQueueInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderCommonLeafQueueInfo(ResponseInfo ri) {
  ri.
  _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
  _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
  _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
  _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
  _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
  _("Max Application Master Resources:", lqinfo.getAMResourceLimit().toString()).
  _("Used Application Master Resources:", lqinfo.getUsedAMResource().toString()).
  _("Max Application Master Resources Per User:", lqinfo.getUserAMResourceLimit().toString()).
  _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
  _("Configured User Limit Factor:", lqinfo.getUserLimitFactor()).
  _("Accessible Node Labels:", StringUtils.join(",", lqinfo.getNodeLabels())).
  _("Ordering Policy: ", lqinfo.getOrderingPolicyInfo()).
  _("Preemption:", lqinfo.getPreemptionDisabled() ? "disabled" : "enabled").
  _("Default Node Label Expression:",
          lqinfo.getDefaultNodeLabelExpression() == null
              ? NodeLabel.DEFAULT_NODE_LABEL_PARTITION
              : lqinfo.getDefaultNodeLabelExpression()).
  _("Default Application Priority:",
          Integer.toString(lqinfo.getDefaultApplicationPriority()));
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:23，代码来源:CapacitySchedulerPage.java

示例7: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  ResponseInfo ri = info("\'" + qinfo.getQueueName() + "\' Queue Status").
      _("Used Resources:", qinfo.getUsedResources().toString()).
      _("Num Active Applications:", qinfo.getNumActiveApplications()).
      _("Num Pending Applications:", qinfo.getNumPendingApplications()).
      _("Min Resources:", qinfo.getMinResources().toString()).
      _("Max Resources:", qinfo.getMaxResources().toString());
  int maxApps = qinfo.getMaxApplications();
  if (maxApps < Integer.MAX_VALUE) {
      ri._("Max Running Applications:", qinfo.getMaxApplications());
  }
  ri._("Fair Share:", qinfo.getFairShare().toString());

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:20，代码来源:FairSchedulerPage.java

示例8: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  ResponseInfo ri = info("\'" + qinfo.getQueueName() + "\' Queue Status").
      _("Used Resources:", qinfo.getUsedResources().toString()).
      _("Demand Resources:", qinfo.getDemandResources().toString()).
      _("Num Active Applications:", qinfo.getNumActiveApplications()).
      _("Num Pending Applications:", qinfo.getNumPendingApplications()).
      _("Min Resources:", qinfo.getMinResources().toString()).
      _("Max Resources:", qinfo.getMaxResources().toString());
  int maxApps = qinfo.getMaxApplications();
  if (maxApps < Integer.MAX_VALUE) {
      ri._("Max Running Applications:", qinfo.getMaxApplications());
  }
  ri._(STEADY_FAIR_SHARE + ":", qinfo.getSteadyFairShare().toString());
  ri._(INSTANTANEOUS_FAIR_SHARE + ":", qinfo.getFairShare().toString());
  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:hopshadoop，项目名称:hops，代码行数:21，代码来源:FairSchedulerPage.java

示例9: renderCommonLeafQueueInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderCommonLeafQueueInfo(ResponseInfo ri) {
  ri.
  _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
  _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
  _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
  _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
  _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
  _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
  _("Configured User Limit Factor:", lqinfo.getUserLimitFactor()).
  _("Accessible Node Labels:", StringUtils.join(",", lqinfo.getNodeLabels())).
  _("Ordering Policy: ", lqinfo.getOrderingPolicyInfo()).
  _("Preemption:", lqinfo.getPreemptionDisabled() ? "disabled" : "enabled").
  _("Default Node Label Expression:",
          lqinfo.getDefaultNodeLabelExpression() == null
              ? NodeLabel.DEFAULT_NODE_LABEL_PARTITION
              : lqinfo.getDefaultNodeLabelExpression()).
  _("Default Application Priority:",
          Integer.toString(lqinfo.getDefaultApplicationPriority()));
}

开发者ID:hopshadoop，项目名称:hops，代码行数:20，代码来源:CapacitySchedulerPage.java

示例10: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  ResponseInfo ri = info("\'" + qinfo.getQueueName() + "\' Queue Status").
      _("Used Resources:", StringEscapeUtils.escapeHtml(
          qinfo.getUsedResources().toString())).
      _("Num Active Applications:", qinfo.getNumActiveApplications()).
      _("Num Pending Applications:", qinfo.getNumPendingApplications()).
      _("Min Resources:", StringEscapeUtils.escapeHtml(
          qinfo.getMinResources().toString())).
      _("Max Resources:", StringEscapeUtils.escapeHtml(
          qinfo.getMaxResources().toString()));
  int maxApps = qinfo.getMaxApplications();
  if (maxApps < Integer.MAX_VALUE) {
      ri._("Max Running Applications:", qinfo.getMaxApplications());
  }
  ri._("Fair Share:", StringEscapeUtils.escapeHtml(
    qinfo.getFairShare().toString()));

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:24，代码来源:FairSchedulerPage.java

示例11: renderLeafQueueInfoWithoutParition

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderLeafQueueInfoWithoutParition(Block html) {
 ResponseInfo ri =
     info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status")
         ._("Queue State:", lqinfo.getQueueState());
 renderQueueCapacityInfo(ri);
 renderCommonLeafQueueInfo(ri);
 html._(InfoBlock.class);
 // clear the info contents so this queue's info doesn't accumulate into
 // another queue's info
  ri.clear();
}

开发者ID:naver，项目名称:hadoop，代码行数:12，代码来源:CapacitySchedulerPage.java

示例12: renderQueueCapacityInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderQueueCapacityInfo(ResponseInfo ri) {
  ri.
  _("Used Capacity:", percent(lqinfo.getUsedCapacity() / 100)).
  _("Configured Capacity:", percent(lqinfo.getCapacity() / 100)).
  _("Configured Max Capacity:", percent(lqinfo.getMaxCapacity() / 100)).
  _("Absolute Used Capacity:", percent(lqinfo.getAbsoluteUsedCapacity() / 100)).
  _("Absolute Configured Capacity:", percent(lqinfo.getAbsoluteCapacity() / 100)).
  _("Absolute Configured Max Capacity:", percent(lqinfo.getAbsoluteMaxCapacity() / 100)).
  _("Used Resources:", lqinfo.getResourcesUsed().toString());
}

开发者ID:naver，项目名称:hadoop，代码行数:11，代码来源:CapacitySchedulerPage.java

示例13: getInstance

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public <T> T getInstance(Class<T> cls) {
  clazz = cls;
  if (cls.equals(ResponseInfo.class)) {
    return (T) responseInfo;
  }
  return (T) view;
}

开发者ID:naver，项目名称:hadoop，代码行数:9，代码来源:AppControllerForTest.java

示例14: renderLeafQueueInfoWithoutParition

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderLeafQueueInfoWithoutParition(Block html) {
  ResponseInfo ri =
      info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status")
          ._("Queue State:", lqinfo.getQueueState());
  renderQueueCapacityInfo(ri, "");
  renderCommonLeafQueueInfo(ri);
  html._(InfoBlock.class);
  // clear the info contents so this queue's info doesn't accumulate into
  // another queue's info
  ri.clear();
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:12，代码来源:CapacitySchedulerPage.java

示例15: renderQueueCapacityInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderQueueCapacityInfo(ResponseInfo ri, String label) {
  PartitionQueueCapacitiesInfo capacities =
      lqinfo.getCapacities().getPartitionQueueCapacitiesInfo(label);
  PartitionResourceUsageInfo resourceUsages =
      lqinfo.getResources().getPartitionResourceUsageInfo(label);
  ri.
  _("Used Capacity:", percent(capacities.getUsedCapacity() / 100)).
  _("Configured Capacity:", percent(capacities.getCapacity() / 100)).
  _("Configured Max Capacity:", percent(capacities.getMaxCapacity() / 100)).
  _("Absolute Used Capacity:", percent(capacities.getAbsoluteUsedCapacity() / 100)).
  _("Absolute Configured Capacity:", percent(capacities.getAbsoluteCapacity() / 100)).
  _("Absolute Configured Max Capacity:", percent(capacities.getAbsoluteMaxCapacity() / 100)).
  _("Used Resources:", resourceUsages.getUsed().toString());
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:15，代码来源:CapacitySchedulerPage.java

示例16: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {

  ResponseInfo ri = info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status").
      _("Queue State:", lqinfo.getQueueState()).
      _("Used Capacity:", percent(lqinfo.getUsedCapacity() / 100)).
      _("Absolute Used Capacity:", percent(lqinfo.getAbsoluteUsedCapacity() / 100)).
      _("Absolute Capacity:", percent(lqinfo.getAbsoluteCapacity() / 100)).
      _("Absolute Max Capacity:", percent(lqinfo.getAbsoluteMaxCapacity() / 100)).
      _("Used Resources:", lqinfo.getResourcesUsed().toString()).
      _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
      _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
      _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
      _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
      _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
      _("Max Application Master Resources:", lqinfo.getAMResourceLimit().toString()).
      _("Used Application Master Resources:", lqinfo.getUsedAMResource().toString()).
      _("Max Application Master Resources Per User:", lqinfo.getUserAMResourceLimit().toString()).
      _("Configured Capacity:", percent(lqinfo.getCapacity() / 100)).
      _("Configured Max Capacity:", percent(lqinfo.getMaxCapacity() / 100)).
      _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
      _("Configured User Limit Factor:", String.format("%.1f", lqinfo.getUserLimitFactor())).
      _("Accessible Node Labels:", StringUtils.join(",", lqinfo.getNodeLabels())).
      _("Preemption:", lqinfo.getPreemptionDisabled() ? "disabled" : "enabled");

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:yncxcw，项目名称:big-c，代码行数:31，代码来源:CapacitySchedulerPage.java

示例17: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  StringBuilder activeUserList = new StringBuilder("");
  ResourceInfo usedResources = lqinfo.getResourcesUsed();
  ArrayList<UserInfo> users = lqinfo.getUsers().getUsersList();
  for (UserInfo entry: users) {
    activeUserList.append(entry.getUsername()).append(" &lt;")
      .append(getPercentage(entry.getResourcesUsed(), usedResources))
      .append(", Schedulable Apps: " + entry.getNumActiveApplications())
      .append(", Non-Schedulable Apps: " + entry.getNumPendingApplications())
      .append("&gt;<br style='display:block'>"); //Force line break
  }

  ResponseInfo ri = info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status").
      _("Queue State:", lqinfo.getQueueState()).
      _("Used Capacity:", percent(lqinfo.getUsedCapacity() / 100)).
      _("Absolute Used Capacity:", percent(lqinfo.getAbsoluteUsedCapacity() / 100)).
      _("Absolute Capacity:", percent(lqinfo.getAbsoluteCapacity() / 100)).
      _("Absolute Max Capacity:", percent(lqinfo.getAbsoluteMaxCapacity() / 100)).
      _("Used Resources:", lqinfo.getResourcesUsed().toString()).
      _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
      _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
      _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
      _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
      _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
      _("Max Schedulable Applications:", Integer.toString(lqinfo.getMaxActiveApplications())).
      _("Max Schedulable Applications Per User:", Integer.toString(lqinfo.getMaxActiveApplicationsPerUser())).
      _("Configured Capacity:", percent(lqinfo.getCapacity() / 100)).
      _("Configured Max Capacity:", percent(lqinfo.getMaxCapacity() / 100)).
      _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
      _("Configured User Limit Factor:", String.format("%.1f", lqinfo.getUserLimitFactor())).
      _("Active Users: ", activeUserList.toString()).
      _r("Accessible Node Labels:", StringUtils.join(",", lqinfo.getNodeLabels()));

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:40，代码来源:CapacitySchedulerPage.java

示例18: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  StringBuilder activeUserList = new StringBuilder("");
  ResourceInfo usedResources = lqinfo.getResourcesUsed();
  ArrayList<UserInfo> users = lqinfo.getUsers().getUsersList();
  for (UserInfo entry: users) {
    activeUserList.append(entry.getUsername()).append(" &lt;")
      .append(getPercentage(entry.getResourcesUsed(), usedResources))
      .append(", Active Apps: " + entry.getNumActiveApplications())
      .append(", Pending Apps: " + entry.getNumPendingApplications())
      .append("&gt;<br style='display:block'>"); //Force line break
  }

  ResponseInfo ri = info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status").
      _("Queue State:", lqinfo.getQueueState()).
      _("Used Capacity:", percent(lqinfo.getUsedCapacity() / 100)).
      _("Absolute Capacity:", percent(lqinfo.getAbsoluteCapacity() / 100)).
      _("Absolute Max Capacity:", percent(lqinfo.getAbsoluteMaxCapacity() / 100)).
      _("Used Resources:", StringEscapeUtils.escapeHtml(lqinfo.getUsedResources().toString())).
      _("Num Active Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
      _("Num Pending Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
      _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
      _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
      _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
      _("Max Active Applications:", Integer.toString(lqinfo.getMaxActiveApplications())).
      _("Max Active Applications Per User:", Integer.toString(lqinfo.getMaxActiveApplicationsPerUser())).
      _("Configured Capacity:", percent(lqinfo.getCapacity() / 100)).
      _("Configured Max Capacity:", percent(lqinfo.getMaxCapacity() / 100)).
      _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
      _("Configured User Limit Factor:", String.format("%.1f", lqinfo.getUserLimitFactor())).
      _r("Active users: ", activeUserList.toString());

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:38，代码来源:CapacitySchedulerPage.java

示例19: renderQueueCapacityInfo

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
private void renderQueueCapacityInfo(ResponseInfo ri, String label) {
  PartitionQueueCapacitiesInfo capacities =
      lqinfo.getCapacities().getPartitionQueueCapacitiesInfo(label);
  PartitionResourcesInfo resourceUsages =
      lqinfo.getResources().getPartitionResourceUsageInfo(label);

  // Get UserInfo from first user to calculate AM Resource Limit per user.
  ResourceInfo userAMResourceLimit = null;
  ArrayList<UserInfo> usersList = lqinfo.getUsers().getUsersList();
  if (usersList.isEmpty()) {
    // If no users are present, consider AM Limit for that queue.
    userAMResourceLimit = resourceUsages.getAMLimit();
  } else {
    userAMResourceLimit = usersList.get(0)
        .getResourceUsageInfo().getPartitionResourceUsageInfo(label)
        .getAMLimit();
  }
  ResourceInfo amUsed = (resourceUsages.getAmUsed() == null)
      ? new ResourceInfo(Resources.none())
      : resourceUsages.getAmUsed();
  ri.
  _("Used Capacity:", percent(capacities.getUsedCapacity() / 100)).
  _("Configured Capacity:", percent(capacities.getCapacity() / 100)).
  _("Configured Max Capacity:", percent(capacities.getMaxCapacity() / 100)).
  _("Absolute Used Capacity:", percent(capacities.getAbsoluteUsedCapacity() / 100)).
  _("Absolute Configured Capacity:", percent(capacities.getAbsoluteCapacity() / 100)).
  _("Absolute Configured Max Capacity:", percent(capacities.getAbsoluteMaxCapacity() / 100)).
  _("Used Resources:", resourceUsages.getUsed().toString()).
  _("Configured Max Application Master Limit:", StringUtils.format("%.1f",
      capacities.getMaxAMLimitPercentage())).
  _("Max Application Master Resources:",
      resourceUsages.getAMLimit().toString()).
  _("Used Application Master Resources:",
      amUsed.toString()).
  _("Max Application Master Resources Per User:",
      userAMResourceLimit.toString());
}

开发者ID:hopshadoop，项目名称:hops，代码行数:38，代码来源:CapacitySchedulerPage.java

示例20: render

import org.apache.hadoop.yarn.webapp.ResponseInfo; //导入依赖的package包/类
@Override
protected void render(Block html) {
  StringBuilder activeUserList = new StringBuilder("");
  ResourceInfo usedResources = lqinfo.getResourcesUsed();
  ArrayList<UserInfo> users = lqinfo.getUsers().getUsersList();
  for (UserInfo entry: users) {
    activeUserList.append(entry.getUsername()).append(" &lt;")
      .append(getPercentage(entry.getResourcesUsed(), usedResources))
      .append(", Schedulable Apps: " + entry.getNumActiveApplications())
      .append(", Non-Schedulable Apps: " + entry.getNumPendingApplications())
      .append("&gt;<br style='display:block'>"); //Force line break
  }

  ResponseInfo ri = info("\'" + lqinfo.getQueuePath().substring(5) + "\' Queue Status").
      _("Queue State:", lqinfo.getQueueState()).
      _("Used Capacity:", percent(lqinfo.getUsedCapacity() / 100)).
      _("Absolute Used Capacity:", percent(lqinfo.getAbsoluteUsedCapacity() / 100)).
      _("Absolute Capacity:", percent(lqinfo.getAbsoluteCapacity() / 100)).
      _("Absolute Max Capacity:", percent(lqinfo.getAbsoluteMaxCapacity() / 100)).
      _("Used Resources:", StringEscapeUtils.escapeHtml(lqinfo.getUsedResources().toString())).
      _("Num Schedulable Applications:", Integer.toString(lqinfo.getNumActiveApplications())).
      _("Num Non-Schedulable Applications:", Integer.toString(lqinfo.getNumPendingApplications())).
      _("Num Containers:", Integer.toString(lqinfo.getNumContainers())).
      _("Max Applications:", Integer.toString(lqinfo.getMaxApplications())).
      _("Max Applications Per User:", Integer.toString(lqinfo.getMaxApplicationsPerUser())).
      _("Max Schedulable Applications:", Integer.toString(lqinfo.getMaxActiveApplications())).
      _("Max Schedulable Applications Per User:", Integer.toString(lqinfo.getMaxActiveApplicationsPerUser())).
      _("Configured Capacity:", percent(lqinfo.getCapacity() / 100)).
      _("Configured Max Capacity:", percent(lqinfo.getMaxCapacity() / 100)).
      _("Configured Minimum User Limit Percent:", Integer.toString(lqinfo.getUserLimit()) + "%").
      _("Configured User Limit Factor:", String.format("%.1f", lqinfo.getUserLimitFactor())).
      _r("Active users: ", activeUserList.toString());

  html._(InfoBlock.class);

  // clear the info contents so this queue's info doesn't accumulate into another queue's info
  ri.clear();
}

开发者ID:chendave，项目名称:hadoop-TCP，代码行数:39，代码来源:CapacitySchedulerPage.java

注：本文中的org.apache.hadoop.yarn.webapp.ResponseInfo类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Failure类代码示例发布时间：2022-05-22

Java Util类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18155|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9637|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8161|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8538|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8440|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9360|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8410|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7848|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8395|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7387|2022-11-06

客服电话

电子邮件

Java ResponseInfo类代码示例

示例1: render

示例2: renderLeafQueueInfoWithPartition

示例3: renderCommonLeafQueueInfo

示例4: testInfo

示例5: renderLeafQueueInfoWithPartition

示例6: renderCommonLeafQueueInfo

示例7: render

示例8: render

示例9: renderCommonLeafQueueInfo

示例10: render

示例11: renderLeafQueueInfoWithoutParition

示例12: renderQueueCapacityInfo

示例13: getInstance

示例14: renderLeafQueueInfoWithoutParition

示例15: renderQueueCapacityInfo

示例16: render

示例17: render

示例18: render

示例19: renderQueueCapacityInfo

示例20: render

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

the-virtual-brain/tvb-library: DEPRECATE

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053