import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@DELETE
@Path("/keep/last/{numPartitions}")
public APIResponse<Map<String, Integer>> keepLastN(
    @PathParam("numPartitions") Integer numPartitions, @Context UriInfo info) {
  long startTs = System.currentTimeMillis();
  int numDeletedPartitions = cube.deleteCube(numPartitions);
  int numOptimizedPartitions = cube.optimize();
  long t0 = System.currentTimeMillis();
  System.gc();
  log.debug("GC took {}ms", System.currentTimeMillis() - t0);
  return new APIResponse<>(
      ImmutableMap.of(
          "numDeletedPartitions", numDeletedPartitions,
          "numOptimizedPartitions", numOptimizedPartitions,
          "gcTimeMs", (int) (System.currentTimeMillis() - t0)),
      info,
      startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@DELETE
@Path("/{cubeName}")
public APIResponse<Map<String, Integer>> deleteCube(
    @PathParam("cubeName") String cubeName, @Context UriInfo info) {
  if (!cube.hasCube(cubeName)) {
    log.warn("Could not find cube {}", cubeName);
    throw new NotFoundException(String.format("Could not find cube %s", cubeName));
  }

  long startTs = System.currentTimeMillis();
  int numDeletedPartitions = cube.deleteCube(cubeName, 0);
  int numOptimizedPartitions = cube.optimize();
  long t0 = System.currentTimeMillis();
  System.gc();
  log.debug("GC took {}ms", System.currentTimeMillis() - t0);
  return new APIResponse<>(
      ImmutableMap.of(
          "numDeletedPartitions", numDeletedPartitions,
          "numOptimizedPartitions", numOptimizedPartitions,
          "gcTimeMs", (int) (System.currentTimeMillis() - t0)),
      info,
      startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@DELETE
@Path("/all/from/{fromPartition}/to/{toPartition}")
public APIResponse<Map<String, Integer>> deletePartitions(
    @PathParam("fromPartition") String fromPartition,
    @PathParam("toPartition") String toPartition,
    @Context UriInfo info) {
  long startTs = System.currentTimeMillis();
  int numDeletedPartitions = cube.deleteCube(fromPartition, toPartition);
  int numOptimizedPartitions = cube.optimize();
  long t0 = System.currentTimeMillis();
  System.gc();
  log.debug("GC took {}ms", System.currentTimeMillis() - t0);
  return new APIResponse<>(
      ImmutableMap.of(
          "numDeletedPartitions", numDeletedPartitions,
          "numOptimizedPartitions", numOptimizedPartitions,
          "gcTimeMs", (int) (System.currentTimeMillis() - t0)),
      info,
      startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@DELETE
@Path("/{cubeName}/from/{fromPartition}/to/{toPartition}")
public APIResponse<Map<String, Integer>> deletePartitionsOfCube(
    @PathParam("cubeName") String cubeName,
    @PathParam("fromPartition") String fromPartition,
    @PathParam("toPartition") String toPartition,
    @Context UriInfo info) {
  if (!cube.hasCube(cubeName)) {
    log.warn("Could not find cube {}", cubeName);
    throw new NotFoundException(String.format("Could not find cube %s", cubeName));
  }

  long startTs = System.currentTimeMillis();
  int numDeletedPartitions = cube.deleteCube(cubeName, fromPartition, toPartition);
  int numOptimizedPartitions = cube.optimize();
  long t0 = System.currentTimeMillis();
  System.gc();
  log.debug("GC took {}ms", System.currentTimeMillis() - t0);
  return new APIResponse<>(
      ImmutableMap.of(
          "numDeletedPartitions", numDeletedPartitions,
          "numOptimizedPartitions", numOptimizedPartitions,
          "gcTimeMs", (int) (System.currentTimeMillis() - t0)),
      info,
      startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
@Parameters({ "gcpName", "gcpInstanceType", "volumeType", "volumeCount", "volumeSize", "preemptible" })
public void testGcpTemplateCreation(@Optional("it-gcp-template") String gcpName, @Optional("n1-standard-2") String gcpInstanceType,
        @Optional("pd-standard") String volumeType, @Optional("1") String volumeCount, @Optional("30") String volumeSize,
        @Optional("false") Boolean preemptible) throws Exception {
    // GIVEN
    // WHEN
    TemplateRequest templateRequest = new TemplateRequest();
    templateRequest.setName(gcpName);
    templateRequest.setDescription("GCP template for integration testing");
    templateRequest.setCloudPlatform("GCP");
    templateRequest.setInstanceType(gcpInstanceType);
    templateRequest.setVolumeCount(Integer.valueOf(volumeCount));
    templateRequest.setVolumeSize(Integer.valueOf(volumeSize));
    templateRequest.setVolumeType(volumeType);
    templateRequest.setCloudPlatform("GCP");
    if (preemptible != null) {
        templateRequest.setParameters(ImmutableMap.of("preemptible", preemptible));
    }
    String id = getCloudbreakClient().templateEndpoint().postPrivate(templateRequest).getId().toString();
    // THEN
    Assert.assertNotNull(id);
    additionHelper.handleTemplateAdditions(getItContext(), id, additions);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void putAll_MapContainsValues_WithMap() {
  RequestParameters parameters = new RequestParameters();

  parameters.putAll(ImmutableMap.of("X", "A", "Y", "B", "Z", "C"));

  Assert.assertEquals("A", parameters.get("X"));
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void asString_ReturnsString_ForExistingEntry() {
  RequestParameters parameters = new RequestParameters();
  parameters.putAll(ImmutableMap.of("X", 1));

  String result = parameters.asString("X");

  Assert.assertEquals("1", result);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void asString_ReturnsNull_ForNonExistentEntry() {
  RequestParameters parameters = new RequestParameters();
  parameters.putAll(ImmutableMap.of("X", "A"));

  String result = parameters.asString("Y");

  Assert.assertNull(result);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void get_ReturnsValue_ForExistentKey() {
  RequestParameters parameters = new RequestParameters();
  parameters.putAll(ImmutableMap.of("X", "A"));

  Object result = parameters.get("X");

  Assert.assertEquals("A", result);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void get_ReturnsNull_ForNonExistentKey() {
  RequestParameters parameters = new RequestParameters();
  parameters.putAll(ImmutableMap.of("X", "A"));

  Object result = parameters.get("Y");

  Assert.assertNull(result);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@POST
@Path("/insert")
public APIResponse<Map<String, Integer>> insert(List<DataRow> rows, @Context UriInfo info) {
  long startTs = System.currentTimeMillis();
  cube.insert(rows);
  log.info("Inserted {} rows", rows.size());
  return new APIResponse<>(ImmutableMap.of("numInsertedRows", rows.size()), info, startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@POST
@Path("/save")
public APIResponse<Map<String, String>> save(@Context UriInfo info) throws IOException {
  final long startTs = System.currentTimeMillis();
  log.info("Saving to {}", cube.getPath());
  cube.save(cube.getPath());
  log.info("Saving finished");
  return new APIResponse<>(ImmutableMap.of("savePath", cube.getPath()), info, startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@POST
@Path("/saveJSON")
public APIResponse<Map<String, String>> dump(@Context UriInfo info) throws IOException {
  final long startTs = System.currentTimeMillis();
  String path = cube.getPath() + "/json";
  log.info("Saving to {}", path);
  cube.saveAsJson(path);
  log.info("Saving finished");
  return new APIResponse<>(ImmutableMap.of("savePath", path), info, startTs);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
public ServerInfo(HashMap<String, WorkerState> workers) {
    this.workers = ImmutableMap.copyOf(workers);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
public ImmutableMap<String, WorkerState> getWorkers() {
    return workers == null ? ImmutableMap.of() : workers;
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Test
public void getComponentMap() throws Exception {
    assertEquals(ImmutableMap.of("site", "mySite"), query.getComponentMap());
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@GET
@Path("status")
public Map<String, String> getTestStatus() {
    return ImmutableMap.of("status", "success");
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@POST
@Path("name")
public Map<String, String> postWithBody(@QueryParam("name") String name) {
    return ImmutableMap.of("name", name);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Override
public Map<String, Object> getParameters() {
    return ImmutableMap.<String, Object>of("name", newEmailName, "folder", folderId);
}
 

import jersey.repackaged.com.google.common.collect.ImmutableMap; //导入依赖的package包/类
@Override
public Map<String, Object> getParameters() {
    return ImmutableMap.<String, Object>of("name", newFormName, "folder", folderId, "description", description);
}