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

YarnContainer.id介绍

暂无

代码示例

代码示例来源：origin: org.apache.samza/samza-yarn_2.11

/**
 * Returns the Id of the Samza container that corresponds to the provided Yarn {@link ContainerId}
 * @param containerId the Yarn ContainerId
 * @return the id of the Samza container corresponding to the {@link ContainerId} that is pending launch
 */
private String getPendingSamzaContainerId(ContainerId containerId) {
 for (String samzaContainerId: state.pendingYarnContainers.keySet()) {
  YarnContainer yarnContainer = state.pendingYarnContainers.get(samzaContainerId);
  if (yarnContainer != null && yarnContainer.id().equals(containerId)) {
   return samzaContainerId;
  }
 }
 return null;
}

代码示例来源：origin: org.apache.samza/samza-yarn

/**
 * Returns the Id of the Samza container that corresponds to the provided Yarn {@link ContainerId}
 * @param containerId the Yarn ContainerId
 * @return the id of the Samza container corresponding to the {@link ContainerId} that is pending launch
 */
private String getPendingSamzaContainerId(ContainerId containerId) {
 for (String samzaContainerId: state.pendingYarnContainers.keySet()) {
  YarnContainer yarnContainer = state.pendingYarnContainers.get(samzaContainerId);
  if (yarnContainer != null && yarnContainer.id().equals(containerId)) {
   return samzaContainerId;
  }
 }
 return null;
}

代码示例来源：origin: org.apache.samza/samza-yarn

/**
 * Given a lookupContainerId from Yarn (for example: containerId_app_12345, this method returns the SamzaContainer ID
 * in the range [0,N-1] that maps to it.
 * @param lookupContainerId  the Yarn container ID.
 * @return  the samza container ID.
 */
//TODO: Get rid of the YarnContainer object and just use Container in state.runningYarnContainers hashmap.
//In that case, this scan will turn into a lookup. This change will require changes/testing in the UI files because
//those UI stub templates operate on the YarnContainer object.
private String getIDForContainer(String lookupContainerId) {
 String samzaContainerID = INVALID_YARN_CONTAINER_ID;
 for(Map.Entry<String, YarnContainer> entry : state.runningYarnContainers.entrySet()) {
  String key = entry.getKey();
  YarnContainer yarnContainer = entry.getValue();
  String yarnContainerId = yarnContainer.id().toString();
  if(yarnContainerId.equals(lookupContainerId)) {
   return key;
  }
 }
 return samzaContainerID;
}

代码示例来源：origin: org.apache.samza/samza-yarn_2.11

/**
 * Given a lookupContainerId from Yarn (for example: containerId_app_12345, this method returns the SamzaContainer ID
 * in the range [0,N-1] that maps to it.
 * @param lookupContainerId  the Yarn container ID.
 * @return  the samza container ID.
 */
//TODO: Get rid of the YarnContainer object and just use Container in state.runningYarnContainers hashmap.
//In that case, this scan will turn into a lookup. This change will require changes/testing in the UI files because
//those UI stub templates operate on the YarnContainer object.
private String getIDForContainer(String lookupContainerId) {
 String samzaContainerID = INVALID_YARN_CONTAINER_ID;
 for(Map.Entry<String, YarnContainer> entry : state.runningYarnContainers.entrySet()) {
  String key = entry.getKey();
  YarnContainer yarnContainer = entry.getValue();
  String yarnContainerId = yarnContainer.id().toString();
  if(yarnContainerId.equals(lookupContainerId)) {
   return key;
  }
 }
 return samzaContainerID;
}

代码示例来源：origin: org.apache.samza/samza-yarn_2.11

@Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  ContainerId yarnContainerId;
  PrintWriter printWriter = resp.getWriter();
  String containerIdParam = req.getParameter(YARN_CONTAINER_ID);
  ContainerHeartbeatResponse response;
  resp.setContentType(APPLICATION_JSON);
  boolean alive = false;
  try {
   yarnContainerId = ContainerId.fromString(containerIdParam);
   for (YarnContainer yarnContainer : yarnAppState.runningYarnContainers.values()) {
    if (yarnContainer.id().compareTo(yarnContainerId) == 0) {
     alive = true;
     break;
    }
   }
   if (!alive) {
    heartbeatsExpiredCount.inc();
   }
   response = new ContainerHeartbeatResponse(alive);
   printWriter.write(mapper.writeValueAsString(response));
  } catch (IllegalArgumentException e) {
   LOG.error("Container ID {} passed is invalid", containerIdParam);
   resp.sendError(HttpServletResponse.SC_BAD_REQUEST, e.getMessage());
  }
 }
}

代码示例来源：origin: org.apache.samza/samza-yarn

@Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  ContainerId yarnContainerId;
  PrintWriter printWriter = resp.getWriter();
  String containerIdParam = req.getParameter(YARN_CONTAINER_ID);
  ContainerHeartbeatResponse response;
  resp.setContentType(APPLICATION_JSON);
  boolean alive = false;
  try {
   yarnContainerId = ContainerId.fromString(containerIdParam);
   for (YarnContainer yarnContainer : yarnAppState.runningYarnContainers.values()) {
    if (yarnContainer.id().compareTo(yarnContainerId) == 0) {
     alive = true;
     break;
    }
   }
   if (!alive) {
    heartbeatsExpiredCount.inc();
   }
   response = new ContainerHeartbeatResponse(alive);
   printWriter.write(mapper.writeValueAsString(response));
  } catch (IllegalArgumentException e) {
   LOG.error("Container ID {} passed is invalid", containerIdParam);
   resp.sendError(HttpServletResponse.SC_BAD_REQUEST, e.getMessage());
  }
 }
}