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

WebServicesTestUtils.checkStringMatch介绍

暂无

代码示例

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

private void verifyJobIdInvalid(String message, String type, String classname) {
 WebServicesTestUtils.checkStringMatch("exception message",
   "java.lang.Exception: JobId string : job_foo is not properly formed",
   message);
 WebServicesTestUtils.checkStringMatch("exception type",
   "NotFoundException", type);
 WebServicesTestUtils.checkStringMatch("exception classname",
   "org.apache.hadoop.yarn.webapp.NotFoundException", classname);
}

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

public void verifyAMInfoGeneric(AppContext ctx, String id, String user,
  String name, long startedOn, long elapsedTime) {
 WebServicesTestUtils.checkStringMatch("id", ctx.getApplicationID()
   .toString(), id);
 WebServicesTestUtils.checkStringMatch("user", ctx.getUser().toString(),
   user);
 WebServicesTestUtils.checkStringMatch("name", ctx.getApplicationName(),
   name);
 assertEquals("startedOn incorrect", ctx.getStartTime(), startedOn);
 assertTrue("elapsedTime not greater then 0", (elapsedTime > 0));
}

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

public void verifyAMJobConfXML(NodeList nodes, Job job) {
 assertEquals("incorrect number of elements", 1, nodes.getLength());
 for (int i = 0; i < nodes.getLength(); i++) {
  Element element = (Element) nodes.item(i);
  WebServicesTestUtils.checkStringMatch("path", job.getConfFile()
    .toString(), WebServicesTestUtils.getXmlString(element, "path"));
  // just do simple verification of fields - not data is correct
  // in the fields
  NodeList properties = element.getElementsByTagName("property");
  for (int j = 0; j < properties.getLength(); j++) {
   Element property = (Element) properties.item(j);
   assertNotNull("should have counters in the web service info", property);
   String name = WebServicesTestUtils.getXmlString(property, "name");
   String value = WebServicesTestUtils.getXmlString(property, "value");
   assertTrue("name not set", (name != null && !name.isEmpty()));
   assertTrue("name not set", (value != null && !value.isEmpty()));
  }
 }
}

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

public void verifyAppAttemptInfoGeneric(RMAppAttempt appAttempt, int id,
  long startTime, String containerId, String nodeHttpAddress, String nodeId,
  String logsLink, String user)
    throws JSONException, Exception {
 assertEquals("id doesn't match", appAttempt.getAppAttemptId()
   .getAttemptId(), id);
 assertEquals("startedTime doesn't match", appAttempt.getStartTime(),
   startTime);
 WebServicesTestUtils.checkStringMatch("containerId", appAttempt
   .getMasterContainer().getId().toString(), containerId);
 WebServicesTestUtils.checkStringMatch("nodeHttpAddress", appAttempt
   .getMasterContainer().getNodeHttpAddress(), nodeHttpAddress);
 WebServicesTestUtils.checkStringMatch("nodeId", appAttempt
   .getMasterContainer().getNodeId().toString(), nodeId);
 assertTrue("logsLink doesn't match ", logsLink.startsWith("http://"));
 assertTrue(
   "logsLink doesn't contain user info", logsLink.endsWith("/"
   + user));
}

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

private void verifyAppAttemptInfoGeneric(RMAppAttempt appAttempt, int id,
     long startTime, String containerId, String nodeHttpAddress, String
     nodeId,
     String logsLink, String user) {

  assertEquals("id doesn't match", appAttempt.getAppAttemptId()
      .getAttemptId(), id);
  assertEquals("startedTime doesn't match", appAttempt.getStartTime(),
      startTime);
  checkStringMatch("containerId", appAttempt
      .getMasterContainer().getId().toString(), containerId);
  checkStringMatch("nodeHttpAddress", appAttempt
      .getMasterContainer().getNodeHttpAddress(), nodeHttpAddress);
  checkStringMatch("nodeId", appAttempt
      .getMasterContainer().getNodeId().toString(), nodeId);
  assertTrue("logsLink doesn't match ", logsLink.startsWith("http://"));
  assertTrue(
      "logsLink doesn't contain user info", logsLink.endsWith("/"
          + user));
 }
}

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

public void verifyAMJobConf(JSONObject info, Job job) throws JSONException {
 assertEquals("incorrect number of elements", 2, info.length());
 WebServicesTestUtils.checkStringMatch("path", job.getConfFile().toString(),
   info.getString("path"));
 // just do simple verification of fields - not data is correct
 // in the fields
 JSONArray properties = info.getJSONArray("property");
 for (int i = 0; i < properties.length(); i++) {
  JSONObject prop = properties.getJSONObject(i);
  String name = prop.getString("name");
  String value = prop.getString("value");
  assertTrue("name not set", (name != null && !name.isEmpty()));
  assertTrue("value not set", (value != null && !value.isEmpty()));
 }
}

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

private void validateJsonExceptionContent(ClientResponse response,
  String expectedmessage)
  throws JSONException {
 Assert.assertEquals(BAD_REQUEST_CODE, response.getStatus());
 JSONObject msg = response.getEntity(JSONObject.class);
 JSONObject exception = msg.getJSONObject("RemoteException");
 String message = exception.getString("message");
 assertEquals("incorrect number of elements", 3, exception.length());
 String type = exception.getString("exception");
 String classname = exception.getString("javaClassName");
 WebServicesTestUtils.checkStringMatch("exception type",
   "BadRequestException", type);
 WebServicesTestUtils.checkStringMatch("exception classname",
   "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
 WebServicesTestUtils.checkStringContains("exception message",
   expectedmessage, message);
}

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

public void verifyTaskGeneric(Task task, String id, String state,
  String type, String successfulAttempt, long startTime, long finishTime,
  long elapsedTime, float progress, String status) {
 TaskId taskid = task.getID();
 String tid = MRApps.toString(taskid);
 TaskReport report = task.getReport();
 WebServicesTestUtils.checkStringMatch("id", tid, id);
 WebServicesTestUtils.checkStringMatch("type", task.getType().toString(),
   type);
 WebServicesTestUtils.checkStringMatch("state", report.getTaskState()
   .toString(), state);
 // not easily checked without duplicating logic, just make sure its here
 assertNotNull("successfulAttempt null", successfulAttempt);
 assertEquals("startTime wrong", report.getStartTime(), startTime);
 assertEquals("finishTime wrong", report.getFinishTime(), finishTime);
 assertEquals("elapsedTime wrong", finishTime - startTime, elapsedTime);
 assertEquals("progress wrong", report.getProgress() * 100, progress, 1e-3f);
 assertEquals("status wrong", report.getStatus(), status);
}

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

@Test
public void testInvalidUri2() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri2() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertEquals(Status.NOT_FOUND, response.getClientResponseStatus());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri2() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.queryParam("user.name", USERS[round])
    .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
   "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri2() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("invalid")
    .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidAccept() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("mapreduce")
    .accept(MediaType.TEXT_PLAIN).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.INTERNAL_SERVER_ERROR,
    response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidAccept() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("cluster")
    .accept(MediaType.TEXT_PLAIN).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.INTERNAL_SERVER_ERROR,
    response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidAccept() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("cluster")
    .accept(MediaType.TEXT_PLAIN).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertEquals(Status.INTERNAL_SERVER_ERROR,
    response.getClientResponseStatus());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("cluster").path("bogus")
    .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertEquals(Status.NOT_FOUND, response.getClientResponseStatus());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("mapreduce").path("bogus")
    .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr = r.path("ws").path("v1").path("cluster").path("bogus")
    .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
    "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidAccept() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr =
    r.path("ws").path("v1").path("applicationhistory")
     .queryParam("user.name", USERS[round])
     .accept(MediaType.TEXT_PLAIN).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.INTERNAL_SERVER_ERROR,
    response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
   "error string exists and shouldn't", "", responseStr);
 }
}

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

@Test
public void testInvalidUri() throws JSONException, Exception {
 WebResource r = resource();
 String responseStr = "";
 try {
  responseStr =
    r.path("ws").path("v1").path("applicationhistory").path("bogus")
     .queryParam("user.name", USERS[round])
     .accept(MediaType.APPLICATION_JSON).get(String.class);
  fail("should have thrown exception on invalid uri");
 } catch (UniformInterfaceException ue) {
  ClientResponse response = ue.getResponse();
  assertResponseStatusCode(Status.NOT_FOUND, response.getStatusInfo());
  WebServicesTestUtils.checkStringMatch(
   "error string exists and shouldn't", "", responseStr);
 }
}