gpt4 book ai didi

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

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

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

WebServicesTestUtils.getXmlString介绍

暂无

代码示例

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

public static int getXmlInt(Element element, String name) {
 String val = getXmlString(element, name);
 return Integer.parseInt(val);
}

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

public static Boolean getXmlBoolean(Element element, String name) {
 String val = getXmlString(element, name);
 return Boolean.parseBoolean(val);
}

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

public static long getXmlLong(Element element, String name) {
 String val = getXmlString(element, name);
 return Long.parseLong(val);
}

代码示例来源:origin: io.hops/hadoop-yarn-common

public static long getXmlLong(Element element, String name) {
 String val = getXmlString(element, name);
 return Long.parseLong(val);
}

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

public static Boolean getXmlBoolean(Element element, String name) {
 String val = getXmlString(element, name);
 return Boolean.parseBoolean(val);
}

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

public static float getXmlFloat(Element element, String name) {
 String val = getXmlString(element, name);
 return Float.parseFloat(val);
}

代码示例来源:origin: io.hops/hadoop-yarn-common

public static int getXmlInt(Element element, String name) {
 String val = getXmlString(element, name);
 return Integer.parseInt(val);
}

代码示例来源:origin: io.hops/hadoop-yarn-common

public static Boolean getXmlBoolean(Element element, String name) {
 String val = getXmlString(element, name);
 return Boolean.parseBoolean(val);
}

代码示例来源:origin: io.hops/hadoop-yarn-common

public static float getXmlFloat(Element element, String name) {
 String val = getXmlString(element, name);
 return Float.parseFloat(val);
}

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

public static long getXmlLong(Element element, String name) {
 String val = getXmlString(element, name);
 return Long.parseLong(val);
}

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

public static float getXmlFloat(Element element, String name) {
 String val = getXmlString(element, name);
 return Float.parseFloat(val);
}

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

public static int getXmlInt(Element element, String name) {
 String val = getXmlString(element, name);
 return Integer.parseInt(val);
}

代码示例来源: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 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-mapreduce-client-app

public void verifyAMSingleTaskXML(Element element, Task task) {
 verifyTaskGeneric(task, WebServicesTestUtils.getXmlString(element, "id"),
   WebServicesTestUtils.getXmlString(element, "state"),
   WebServicesTestUtils.getXmlString(element, "type"),
   WebServicesTestUtils.getXmlString(element, "successfulAttempt"),
   WebServicesTestUtils.getXmlLong(element, "startTime"),
   WebServicesTestUtils.getXmlLong(element, "finishTime"),
   WebServicesTestUtils.getXmlLong(element, "elapsedTime"),
   WebServicesTestUtils.getXmlFloat(element, "progress"),
   WebServicesTestUtils.getXmlString(element, "status"));
}

代码示例来源: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: org.apache.hadoop/hadoop-yarn-server-resourcemanager

private void verifyResourceUsageInfoXML(Element queueChildElem) {
 NodeList resourceUsageInfo = queueChildElem.getChildNodes();
 assertEquals("incorrect number of partitions", 1,
   resourceUsageInfo.getLength());
 Element partitionResourceUsageInfo = (Element) resourceUsageInfo.item(0);
 String partitionName = WebServicesTestUtils
   .getXmlString(partitionResourceUsageInfo, "partitionName");
 assertTrue("invalid PartitionCapacityInfo",
   DEFAULT_PARTITION.equals(partitionName));
}

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

protected static void
  verifyAppQueueXML(ClientResponse response, String queue)
    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("appqueue");
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 Element element = (Element) nodes.item(0);
 String responseQueue = WebServicesTestUtils.getXmlString(element, "queue");
 assertEquals(queue, responseQueue);
}

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

protected static void
  verifyAppQueueXML(ClientResponse response, String queue)
    throws ParserConfigurationException, IOException, SAXException {
 assertEquals(MediaType.APPLICATION_XML_TYPE, response.getType());
 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("appqueue");
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 Element element = (Element) nodes.item(0);
 String responseQueue = WebServicesTestUtils.getXmlString(element, "queue");
 assertEquals(queue, responseQueue);
}

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

public void verifyAMTaskXML(NodeList nodes, Job job) {
 assertEquals("incorrect number of elements", 2, nodes.getLength());
 for (Task task : job.getTasks().values()) {
  TaskId id = task.getID();
  String tid = MRApps.toString(id);
  Boolean found = false;
  for (int i = 0; i < nodes.getLength(); i++) {
   Element element = (Element) nodes.item(i);
   if (tid.matches(WebServicesTestUtils.getXmlString(element, "id"))) {
    found = true;
    verifyAMSingleTaskXML(element, task);
   }
  }
  assertTrue("task with id: " + tid + " not in web service output", found);
 }
}

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