gpt4 book ai didi

org.apache.hadoop.yarn.webapp.WebServicesTestUtils.getXmlInt()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-22 20:29:05 26 4
gpt4 key购买 nike

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

WebServicesTestUtils.getXmlInt介绍

暂无

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlInt(element, "appsSubmitted"),
WebServicesTestUtils.getXmlInt(element, "appsCompleted"),
WebServicesTestUtils.getXmlInt(element, "reservedMB"),
WebServicesTestUtils.getXmlInt(element, "availableMB"),
WebServicesTestUtils.getXmlInt(element, "allocatedMB"),
WebServicesTestUtils.getXmlInt(element, "reservedVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "availableVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "allocatedVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "totalVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "containersAllocated"),
WebServicesTestUtils.getXmlInt(element, "totalMB"),
WebServicesTestUtils.getXmlInt(element, "totalNodes"),
WebServicesTestUtils.getXmlInt(element, "lostNodes"),
WebServicesTestUtils.getXmlInt(element, "unhealthyNodes"),
WebServicesTestUtils.getXmlInt(element, "decommissionedNodes"),
WebServicesTestUtils.getXmlInt(element, "rebootedNodes"),
WebServicesTestUtils.getXmlInt(element, "activeNodes"),
WebServicesTestUtils.getXmlInt(element, "shutdownNodes"));

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlInt(element, "appsSubmitted"),
WebServicesTestUtils.getXmlInt(element, "appsCompleted"),
WebServicesTestUtils.getXmlInt(element, "reservedMB"),
WebServicesTestUtils.getXmlInt(element, "availableMB"),
WebServicesTestUtils.getXmlInt(element, "allocatedMB"),
WebServicesTestUtils.getXmlInt(element, "reservedVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "availableVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "allocatedVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "totalVirtualCores"),
WebServicesTestUtils.getXmlInt(element, "containersAllocated"),
WebServicesTestUtils.getXmlInt(element, "totalMB"),
WebServicesTestUtils.getXmlInt(element, "totalNodes"),
WebServicesTestUtils.getXmlInt(element, "lostNodes"),
WebServicesTestUtils.getXmlInt(element, "unhealthyNodes"),
WebServicesTestUtils.getXmlInt(element, "decommissionedNodes"),
WebServicesTestUtils.getXmlInt(element, "rebootedNodes"),
WebServicesTestUtils.getXmlInt(element, "activeNodes"));

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public void verifySchedulerFifoXML(String xml) throws JSONException,
  Exception {
 DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
 DocumentBuilder db = dbf.newDocumentBuilder();
 InputSource is = new InputSource();
 is.setCharacterStream(new StringReader(xml));
 Document dom = db.parse(is);
 NodeList nodesSched = dom.getElementsByTagName("scheduler");
 assertEquals("incorrect number of elements", 1, nodesSched.getLength());
 NodeList nodes = dom.getElementsByTagName("schedulerInfo");
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyClusterSchedulerFifoGeneric(
    WebServicesTestUtils.getXmlAttrString(element, "xsi:type"),
    WebServicesTestUtils.getXmlString(element, "qstate"),
    WebServicesTestUtils.getXmlFloat(element, "capacity"),
    WebServicesTestUtils.getXmlFloat(element, "usedCapacity"),
    WebServicesTestUtils.getXmlInt(element, "minQueueMemoryCapacity"),
    WebServicesTestUtils.getXmlInt(element, "maxQueueMemoryCapacity"),
    WebServicesTestUtils.getXmlInt(element, "numNodes"),
    WebServicesTestUtils.getXmlInt(element, "usedNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "availNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "totalNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "numContainers"));
 }
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public void verifySchedulerFifoXML(String xml) throws JSONException,
  Exception {
 DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
 DocumentBuilder db = dbf.newDocumentBuilder();
 InputSource is = new InputSource();
 is.setCharacterStream(new StringReader(xml));
 Document dom = db.parse(is);
 NodeList nodesSched = dom.getElementsByTagName("scheduler");
 assertEquals("incorrect number of elements", 1, nodesSched.getLength());
 NodeList nodes = dom.getElementsByTagName("schedulerInfo");
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyClusterSchedulerFifoGeneric(
    WebServicesTestUtils.getXmlAttrString(element, "xsi:type"),
    WebServicesTestUtils.getXmlString(element, "qstate"),
    WebServicesTestUtils.getXmlFloat(element, "capacity"),
    WebServicesTestUtils.getXmlFloat(element, "usedCapacity"),
    WebServicesTestUtils.getXmlInt(element, "minQueueMemoryCapacity"),
    WebServicesTestUtils.getXmlInt(element, "maxQueueMemoryCapacity"),
    WebServicesTestUtils.getXmlInt(element, "numNodes"),
    WebServicesTestUtils.getXmlInt(element, "usedNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "availNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "totalNodeCapacity"),
    WebServicesTestUtils.getXmlInt(element, "numContainers"));
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

protected static void verifyAppPriorityXML(ClientResponse response,
  int expectedPriority)
    throws ParserConfigurationException, IOException, SAXException {
 assertEquals(MediaType.APPLICATION_XML_TYPE + "; " + JettyUtils.UTF_8,
   response.getType().toString());
 String xml = response.getEntity(String.class);
 DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
 DocumentBuilder db = dbf.newDocumentBuilder();
 InputSource is = new InputSource();
 is.setCharacterStream(new StringReader(xml));
 Document dom = db.parse(is);
 NodeList nodes = dom.getElementsByTagName("applicationpriority");
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 Element element = (Element) nodes.item(0);
 int responsePriority = WebServicesTestUtils.getXmlInt(element, "priority");
 assertEquals(expectedPriority, responsePriority);
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-app

WebServicesTestUtils.getXmlLong(element, "finishTime"),
WebServicesTestUtils.getXmlLong(element, "elapsedTime"),
WebServicesTestUtils.getXmlInt(element, "mapsTotal"),
WebServicesTestUtils.getXmlInt(element, "mapsCompleted"),
WebServicesTestUtils.getXmlInt(element, "reducesTotal"),
WebServicesTestUtils.getXmlInt(element, "reducesCompleted"),
WebServicesTestUtils.getXmlFloat(element, "reduceProgress"),
WebServicesTestUtils.getXmlFloat(element, "mapProgress"));
WebServicesTestUtils.getXmlInt(element, "mapsPending"),
WebServicesTestUtils.getXmlInt(element, "mapsRunning"),
WebServicesTestUtils.getXmlInt(element, "reducesPending"),
WebServicesTestUtils.getXmlInt(element, "reducesRunning"),
WebServicesTestUtils.getXmlBoolean(element, "uberized"),
WebServicesTestUtils.getXmlString(element, "diagnostics"),
WebServicesTestUtils.getXmlInt(element, "newReduceAttempts"),
WebServicesTestUtils.getXmlInt(element, "runningReduceAttempts"),
WebServicesTestUtils.getXmlInt(element, "failedReduceAttempts"),
WebServicesTestUtils.getXmlInt(element, "killedReduceAttempts"),
WebServicesTestUtils.getXmlInt(element, "successfulReduceAttempts"),
WebServicesTestUtils.getXmlInt(element, "newMapAttempts"),
WebServicesTestUtils.getXmlInt(element, "runningMapAttempts"),
WebServicesTestUtils.getXmlInt(element, "failedMapAttempts"),
WebServicesTestUtils.getXmlInt(element, "killedMapAttempts"),
WebServicesTestUtils.getXmlInt(element, "successfulMapAttempts"));

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlLong(element, "lastHealthUpdate"),
WebServicesTestUtils.getXmlString(element, "healthReport"),
WebServicesTestUtils.getXmlInt(element, "numContainers"),
WebServicesTestUtils.getXmlLong(element, "usedMemoryMB"),
WebServicesTestUtils.getXmlLong(element, "availMemoryMB"),
WebServicesTestUtils.getXmlLong(element,  "availableVirtualCores"),
WebServicesTestUtils.getXmlString(element, "version"),
WebServicesTestUtils.getXmlInt(element, "nodePhysicalMemoryMB"),
WebServicesTestUtils.getXmlInt(element, "nodeVirtualMemoryMB"),
WebServicesTestUtils.getXmlFloat(element, "nodeCPUUsage"),
WebServicesTestUtils.getXmlInt(element,
  "aggregatedContainersPhysicalMemoryMB"),
WebServicesTestUtils.getXmlInt(element,
  "aggregatedContainersVirtualMemoryMB"),
WebServicesTestUtils.getXmlFloat(element, "containersCPUUsage"),
WebServicesTestUtils.getXmlInt(element, "numRunningOpportContainers"),
WebServicesTestUtils.getXmlLong(element, "usedMemoryOpportGB"),
WebServicesTestUtils.getXmlInt(element, "usedVirtualCoresOpport"),
WebServicesTestUtils.getXmlInt(element, "numQueuedContainers"));

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlFloat(qElem, "absoluteUsedCapacity");
qi.numApplications =
  WebServicesTestUtils.getXmlInt(qElem, "numApplications");
qi.queueName = WebServicesTestUtils.getXmlString(qElem, "queueName");
qi.state = WebServicesTestUtils.getXmlString(qElem, "state");
 LeafQueueInfo lqi = (LeafQueueInfo) qi;
 lqi.numActiveApplications =
   WebServicesTestUtils.getXmlInt(qElem, "numActiveApplications");
 lqi.numPendingApplications =
   WebServicesTestUtils.getXmlInt(qElem, "numPendingApplications");
 lqi.numContainers =
   WebServicesTestUtils.getXmlInt(qElem, "numContainers");
 lqi.maxApplications =
   WebServicesTestUtils.getXmlInt(qElem, "maxApplications");
 lqi.maxApplicationsPerUser =
   WebServicesTestUtils.getXmlInt(qElem, "maxApplicationsPerUser");
 lqi.userLimit = WebServicesTestUtils.getXmlInt(qElem, "userLimit");
 lqi.userLimitFactor =
   WebServicesTestUtils.getXmlFloat(qElem, "userLimitFactor");

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlFloat(qElem, "absoluteUsedCapacity");
qi.numApplications =
  WebServicesTestUtils.getXmlInt(qElem, "numApplications");
qi.queueName = WebServicesTestUtils.getXmlString(qElem, "queueName");
qi.state = WebServicesTestUtils.getXmlString(qElem, "state");
 LeafQueueInfo lqi = (LeafQueueInfo) qi;
 lqi.numActiveApplications =
   WebServicesTestUtils.getXmlInt(qElem, "numActiveApplications");
 lqi.numPendingApplications =
   WebServicesTestUtils.getXmlInt(qElem, "numPendingApplications");
 lqi.numContainers =
   WebServicesTestUtils.getXmlInt(qElem, "numContainers");
 lqi.maxApplications =
   WebServicesTestUtils.getXmlInt(qElem, "maxApplications");
 lqi.maxApplicationsPerUser =
   WebServicesTestUtils.getXmlInt(qElem, "maxApplicationsPerUser");
 lqi.userLimit = WebServicesTestUtils.getXmlInt(qElem, "userLimit");
 lqi.userLimitFactor =
   WebServicesTestUtils.getXmlFloat(qElem, "userLimitFactor");

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

private void verifyAppAttemptsXML(NodeList nodes, RMAppAttempt appAttempt,
    String user) {
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyAppAttemptInfoGeneric(appAttempt,
      WebServicesTestUtils.getXmlInt(element, "id"),
      WebServicesTestUtils.getXmlLong(element, "startTime"),
      WebServicesTestUtils.getXmlString(element, "containerId"),
      WebServicesTestUtils.getXmlString(element, "nodeHttpAddress"),
      WebServicesTestUtils.getXmlString(element, "nodeId"),
      WebServicesTestUtils.getXmlString(element, "logsLink"), user);
 }
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public void verifyAppsXML(NodeList nodes, RMApp app) throws JSONException,
  Exception {
  for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyAppInfoGeneric(app,
    WebServicesTestUtils.getXmlString(element, "id"),
    WebServicesTestUtils.getXmlString(element, "user"),
    WebServicesTestUtils.getXmlString(element, "name"),
    WebServicesTestUtils.getXmlString(element, "applicationType"),
    WebServicesTestUtils.getXmlString(element, "queue"),
    WebServicesTestUtils.getXmlString(element, "state"),
    WebServicesTestUtils.getXmlString(element, "finalStatus"),
    WebServicesTestUtils.getXmlFloat(element, "progress"),
    WebServicesTestUtils.getXmlString(element, "trackingUI"),
    WebServicesTestUtils.getXmlString(element, "diagnostics"),
    WebServicesTestUtils.getXmlLong(element, "clusterId"),
    WebServicesTestUtils.getXmlLong(element, "startedTime"),
    WebServicesTestUtils.getXmlLong(element, "finishedTime"),
    WebServicesTestUtils.getXmlLong(element, "elapsedTime"),
    WebServicesTestUtils.getXmlString(element, "amHostHttpAddress"),
    WebServicesTestUtils.getXmlString(element, "amContainerLogs"),
    WebServicesTestUtils.getXmlInt(element, "allocatedMB"),
    WebServicesTestUtils.getXmlInt(element, "allocatedVCores"),
    WebServicesTestUtils.getXmlInt(element, "runningContainers"),
    WebServicesTestUtils.getXmlInt(element, "preemptedResourceMB"),
    WebServicesTestUtils.getXmlInt(element, "preemptedResourceVCores"),
    WebServicesTestUtils.getXmlInt(element, "numNonAMContainerPreempted"),
    WebServicesTestUtils.getXmlInt(element, "numAMContainerPreempted"));
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-app

public void verifyJobAttemptsXML(NodeList nodes, Job job) {
 assertEquals("incorrect number of elements", 2, nodes.getLength());
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyJobAttemptsGeneric(job,
    WebServicesTestUtils.getXmlString(element, "nodeHttpAddress"),
    WebServicesTestUtils.getXmlString(element, "nodeId"),
    WebServicesTestUtils.getXmlInt(element, "id"),
    WebServicesTestUtils.getXmlLong(element, "startTime"),
    WebServicesTestUtils.getXmlString(element, "containerId"),
    WebServicesTestUtils.getXmlString(element, "logsLink"));
 }
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public void verifyAppAttemptsXML(NodeList nodes, RMAppAttempt appAttempt,
  String user)
  throws JSONException, Exception {
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyAppAttemptInfoGeneric(appAttempt,
    WebServicesTestUtils.getXmlInt(element, "id"),
    WebServicesTestUtils.getXmlLong(element, "startTime"),
    WebServicesTestUtils.getXmlString(element, "containerId"),
    WebServicesTestUtils.getXmlString(element, "nodeHttpAddress"),
    WebServicesTestUtils.getXmlString(element, "nodeId"),
    WebServicesTestUtils.getXmlString(element, "logsLink"), user);
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

WebServicesTestUtils.getXmlString(element, "applicationType"),
WebServicesTestUtils.getXmlString(element, "queue"),
WebServicesTestUtils.getXmlInt(element, "priority"),
WebServicesTestUtils.getXmlString(element, "state"),
WebServicesTestUtils.getXmlString(element, "finalStatus"),
WebServicesTestUtils.getXmlString(element, "amHostHttpAddress"),
WebServicesTestUtils.getXmlString(element, "amContainerLogs"),
WebServicesTestUtils.getXmlInt(element, "allocatedMB"),
WebServicesTestUtils.getXmlInt(element, "allocatedVCores"),
WebServicesTestUtils.getXmlInt(element, "runningContainers"),
WebServicesTestUtils.getXmlFloat(element, "queueUsagePercentage"),
WebServicesTestUtils.getXmlFloat(element, "clusterUsagePercentage"),
WebServicesTestUtils.getXmlInt(element, "preemptedResourceMB"),
WebServicesTestUtils.getXmlInt(element, "preemptedResourceVCores"),
WebServicesTestUtils.getXmlInt(element, "numNonAMContainerPreempted"),
WebServicesTestUtils.getXmlInt(element, "numAMContainerPreempted"),
WebServicesTestUtils.getXmlString(element, "logAggregationStatus"),
WebServicesTestUtils.getXmlBoolean(element, "unmanagedApplication"),
 WebServicesTestUtils.getXmlString(resourceRequests,
   "nodeLabelExpression"),
 WebServicesTestUtils.getXmlInt(resourceRequests, "numContainers"),
 WebServicesTestUtils.getXmlBoolean(resourceRequests, "relaxLocality"),
 WebServicesTestUtils.getXmlInt(resourceRequests, "priority"),
 WebServicesTestUtils.getXmlString(resourceRequests, "resourceName"),
 WebServicesTestUtils.getXmlLong(capability, "memory"),

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public void verifyNodesXML(NodeList nodes, MockNM nm) throws JSONException,
  Exception {
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  verifyNodeInfoGeneric(nm,
    WebServicesTestUtils.getXmlString(element, "state"),
    WebServicesTestUtils.getXmlString(element, "rack"),
    WebServicesTestUtils.getXmlString(element, "id"),
    WebServicesTestUtils.getXmlString(element, "nodeHostName"),
    WebServicesTestUtils.getXmlString(element, "nodeHTTPAddress"),
    WebServicesTestUtils.getXmlLong(element, "lastHealthUpdate"),
    WebServicesTestUtils.getXmlString(element, "healthReport"),
    WebServicesTestUtils.getXmlInt(element, "numContainers"),
    WebServicesTestUtils.getXmlLong(element, "usedMemoryMB"),
    WebServicesTestUtils.getXmlLong(element, "availMemoryMB"),
    WebServicesTestUtils.getXmlLong(element, "usedVirtualCores"),
    WebServicesTestUtils.getXmlLong(element,  "availableVirtualCores"),
    WebServicesTestUtils.getXmlString(element, "version"));
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

assertEquals("numContainers doesn't match",
  resourceRequest.getNumContainers(),
  getXmlInt(requestInfo, "numContainers"));
assertEquals("relaxLocality doesn't match",
  resourceRequest.getRelaxLocality(),
assertEquals("priority does not match",
  resourceRequest.getPriority().getPriority(),
  getXmlInt(requestInfo, "priority"));
assertEquals("resourceName does not match",
  resourceRequest.getResourceName(),

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

checkStringMatch("queue", app.getQueue(),
    getXmlString(info, "queue"));
assertEquals("priority doesn't match", 0, getXmlInt(info, "priority"));
checkStringMatch("state", app.getState().toString(),
    getXmlString(info, "state"));
  getXmlString(info, "amContainerLogs").endsWith("/" + app.getUser()));
assertEquals("allocatedMB doesn't match", 1024,
    getXmlInt(info, "allocatedMB"));
assertEquals("allocatedVCores doesn't match", 1,
    getXmlInt(info, "allocatedVCores"));
assertEquals("queueUsagePerc doesn't match", 50.0f,
    getXmlFloat(info, "queueUsagePercentage"), 0.01f);
    getXmlFloat(info, "clusterUsagePercentage"), 0.01f);
assertEquals("numContainers doesn't match", 1,
  getXmlInt(info, "runningContainers"));
assertNotNull("preemptedResourceSecondsMap should not be null",
    info.getElementsByTagName("preemptedResourceSecondsMap"));
assertEquals("preemptedResourceMB doesn't match", app
        .getRMAppMetrics().getResourcePreempted().getMemorySize(),
    getXmlInt(info, "preemptedResourceMB"));
assertEquals("preemptedResourceVCores doesn't match", app
        .getRMAppMetrics().getResourcePreempted().getVirtualCores(),
    getXmlInt(info, "preemptedResourceVCores"));
assertEquals("numNonAMContainerPreempted doesn't match", app
        .getRMAppMetrics().getNumNonAMContainersPreempted(),
    getXmlInt(info, "numNonAMContainerPreempted"));
assertEquals("numAMContainerPreempted doesn't match", app

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com