1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.rest.model.StorageClusterVersionModel

Java 类org.apache.hadoop.hbase.rest.model.StorageClusterVersionModel 实例源码

项目：ditb    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：LCIndex-HBase-0.94.16    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：HIndex    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：IRIndex    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：hbase    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isTraceEnabled()) {
    LOG.trace("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(
      servlet.getAdmin().getClusterMetrics(EnumSet.of(Option.HBASE_VERSION))
          .getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：RStore    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    HBaseAdmin admin = new HBaseAdmin(servlet.getConfiguration());
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(admin.getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    return response.build();
  } catch (IOException e) {
    throw new WebApplicationException(e, 
                Response.Status.SERVICE_UNAVAILABLE);
  }
}
项目：PyroDB    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：c5    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：HBase-Research    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：hbase-0.94.8-qod    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：hbase-0.94.8-qod    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：DominoHBase    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：hindex    文件：StorageClusterVersionResource.java    
@GET
@Produces({MIMETYPE_TEXT, MIMETYPE_XML, MIMETYPE_JSON})
public Response get(final @Context UriInfo uriInfo) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("GET " + uriInfo.getAbsolutePath());
  }
  servlet.getMetrics().incrementRequests(1);
  try {
    StorageClusterVersionModel model = new StorageClusterVersionModel();
    model.setVersion(servlet.getAdmin().getClusterStatus().getHBaseVersion());
    ResponseBuilder response = Response.ok(model);
    response.cacheControl(cacheControl);
    servlet.getMetrics().incrementSucessfulGetRequests(1);
    return response.build();
  } catch (IOException e) {
    servlet.getMetrics().incrementFailedGetRequests(1);
    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
      .type(MIMETYPE_TEXT).entity("Unavailable" + CRLF)
      .build();
  }
}
项目：ditb    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：ditb    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：ditb    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as XML");
}
项目：LCIndex-HBase-0.94.16    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：LCIndex-HBase-0.94.16    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：LCIndex-HBase-0.94.16    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
}
项目：HIndex    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：HIndex    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：HIndex    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as XML");
}
项目：IRIndex    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：IRIndex    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：IRIndex    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
}
项目：hbase    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：hbase    文件：TestXmlParsing.java    
@Test
public void testParsingClusterVersion() throws Exception {
  final String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>"
      + "<ClusterVersion Version=\"2.0.0\"/>";
  Client client = mock(Client.class);
  RemoteAdmin admin = new RemoteAdmin(client, HBaseConfiguration.create(), null);
  Response resp = new Response(200, null, Bytes.toBytes(xml));

  when(client.get("/version/cluster", Constants.MIMETYPE_XML)).thenReturn(resp);

  StorageClusterVersionModel cv = admin.getClusterVersion();
  assertEquals("2.0.0", cv.getVersion());
}
项目：hbase    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：hbase    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertEquals(200, response.getCode());
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel =
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as XML");
}
项目：hbase    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionJSON() throws IOException {
  Response response = client.get("/version/cluster", Constants.MIMETYPE_JSON);
  assertEquals(200, response.getCode());
  assertEquals(Constants.MIMETYPE_JSON, response.getHeader("content-type"));
  ObjectMapper mapper = new JacksonJaxbJsonProvider()
          .locateMapper(StorageClusterVersionModel.class, MediaType.APPLICATION_JSON_TYPE);
  StorageClusterVersionModel clusterVersionModel
          = mapper.readValue(response.getBody(), StorageClusterVersionModel.class);
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as JSON");
}
项目：PyroDB    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：PyroDB    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：PyroDB    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as XML");
}
项目：c5    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：c5    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：c5    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
  LOG.info("success retrieving storage cluster version as XML");
}
项目：HBase-Research    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }
项目：HBase-Research    文件：TestVersionResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    VersionModel.class,
    StorageClusterVersionModel.class);
}
项目：HBase-Research    文件：TestVersionResource.java    
@Test
public void testGetStorageClusterVersionXML() throws IOException,
    JAXBException {
  Response response = client.get("/version/cluster",Constants.MIMETYPE_XML);
  assertTrue(response.getCode() == 200);
  assertEquals(Constants.MIMETYPE_XML, response.getHeader("content-type"));
  StorageClusterVersionModel clusterVersionModel = 
    (StorageClusterVersionModel)
      context.createUnmarshaller().unmarshal(
        new ByteArrayInputStream(response.getBody()));
  assertNotNull(clusterVersionModel);
  assertNotNull(clusterVersionModel.getVersion());
}
项目：hbase-0.94.8-qod    文件：RemoteAdmin.java    
static Unmarshaller getUnmarsheller() throws JAXBException {

    if (versionClusterUnmarshaller == null) {

      RemoteAdmin.versionClusterUnmarshaller = JAXBContext.newInstance(
          StorageClusterVersionModel.class).createUnmarshaller();
    }
    return RemoteAdmin.versionClusterUnmarshaller;
  }