org.apache.hadoop.yarn.api.records.Container.setNodeHttpAddress()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(138)

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

Container.setNodeHttpAddress介绍

暂无

代码示例

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-common

public static Container newContainer(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = recordFactory.newRecordInstance(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

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

public static Container newContainer(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = recordFactory.newRecordInstance(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

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

public static Container newContainer(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = recordFactory.newRecordInstance(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-api

@Private
@Unstable
public static Container newInstance(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = Records.newRecord(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

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

@Private
@Unstable
public static Container newInstance(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = Records.newRecord(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

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

@Private
@Unstable
public static Container newInstance(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken) {
 Container container = Records.newRecord(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 return container;
}

代码示例来源：origin: apache/incubator-slider

NodeId nodeId = NodeId.newInstance(host, amPort);
container.setNodeId(nodeId);
container.setNodeHttpAddress(nodeHttpAddress);
RoleInstance am = new RoleInstance(container);
am.role = SliderKeys.COMPONENT_AM;

代码示例来源：origin: org.apache.slider/slider-core

NodeId nodeId = NodeId.newInstance(host, amPort);
container.setNodeId(nodeId);
container.setNodeHttpAddress(nodeHttpAddress);
RoleInstance am = new RoleInstance(container);
am.role = SliderKeys.COMPONENT_AM;

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

@Private
@Unstable
public static Container newInstance(ContainerId containerId, NodeId nodeId,
  String nodeHttpAddress, Resource resource, Priority priority,
  Token containerToken, ExecutionType executionType) {
 Container container = Records.newRecord(Container.class);
 container.setId(containerId);
 container.setNodeId(nodeId);
 container.setNodeHttpAddress(nodeHttpAddress);
 container.setResource(resource);
 container.setPriority(priority);
 container.setContainerToken(containerToken);
 container.setExecutionType(executionType);
 return container;
}

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

container.setNodeId(nodeId);
container.setContainerToken(null);
container.setNodeHttpAddress("localhost:8042");
getContext().getEventHandler()
  .handle(

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

@SuppressWarnings("unchecked")
@Override
public void handle(ContainerAllocatorEvent event) {
 if (event.getType() == ContainerAllocator.EventType.CONTAINER_REQ) {
  LOG.info("Processing the event " + event.toString());
  // Assign the same container ID as the AM
  ContainerId cID =
    ContainerId.newContainerId(getContext().getApplicationAttemptId(),
     this.containerId.getContainerId());
  Container container = recordFactory.newRecordInstance(Container.class);
  container.setId(cID);
  NodeId nodeId = NodeId.newInstance(this.nmHost, this.nmPort);
  container.setNodeId(nodeId);
  container.setContainerToken(null);
  container.setNodeHttpAddress(this.nmHost + ":" + this.nmHttpPort);
  // send the container-assigned event to task attempt
  if (event.getAttemptID().getTaskId().getTaskType() == TaskType.MAP) {
   JobCounterUpdateEvent jce =
     new JobCounterUpdateEvent(event.getAttemptID().getTaskId()
       .getJobId());
   // TODO Setting OTHER_LOCAL_MAP for now.
   jce.addCounterUpdate(JobCounter.OTHER_LOCAL_MAPS, 1);
   eventHandler.handle(jce);
  }
  eventHandler.handle(new TaskAttemptContainerAssignedEvent(
    event.getAttemptID(), container, applicationACLs));
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

@SuppressWarnings("unchecked")
@Override
public void handle(ContainerAllocatorEvent event) {
 if (event.getType() == ContainerAllocator.EventType.CONTAINER_REQ) {
  LOG.info("Processing the event " + event.toString());
  // Assign the same container ID as the AM
  ContainerId cID =
    ContainerId.newContainerId(getContext().getApplicationAttemptId(),
     this.containerId.getContainerId());
  Container container = recordFactory.newRecordInstance(Container.class);
  container.setId(cID);
  NodeId nodeId = NodeId.newInstance(this.nmHost, this.nmPort);
  container.setNodeId(nodeId);
  container.setContainerToken(null);
  container.setNodeHttpAddress(this.nmHost + ":" + this.nmHttpPort);
  // send the container-assigned event to task attempt
  if (event.getAttemptID().getTaskId().getTaskType() == TaskType.MAP) {
   JobCounterUpdateEvent jce =
     new JobCounterUpdateEvent(event.getAttemptID().getTaskId()
       .getJobId());
   // TODO Setting OTHER_LOCAL_MAP for now.
   jce.addCounterUpdate(JobCounter.OTHER_LOCAL_MAPS, 1);
   eventHandler.handle(jce);
  }
  eventHandler.handle(new TaskAttemptContainerAssignedEvent(
    event.getAttemptID(), container, applicationACLs));
 }
}

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

@SuppressWarnings("unchecked")
@Override
public void handle(ContainerAllocatorEvent event) {
 if (event.getType() == ContainerAllocator.EventType.CONTAINER_REQ) {
  LOG.info("Processing the event " + event.toString());
  // Assign the same container ID as the AM
  ContainerId cID =
    ContainerId.newContainerId(getContext().getApplicationAttemptId(),
     this.containerId.getContainerId());
  Container container = recordFactory.newRecordInstance(Container.class);
  container.setId(cID);
  NodeId nodeId = NodeId.newInstance(this.nmHost, this.nmPort);
  container.setResource(Resource.newInstance(0, 0));
  container.setNodeId(nodeId);
  container.setContainerToken(null);
  container.setNodeHttpAddress(this.nmHost + ":" + this.nmHttpPort);
  // send the container-assigned event to task attempt
  if (event.getAttemptID().getTaskId().getTaskType() == TaskType.MAP) {
   JobCounterUpdateEvent jce =
     new JobCounterUpdateEvent(event.getAttemptID().getTaskId()
       .getJobId());
   // TODO Setting OTHER_LOCAL_MAP for now.
   jce.addCounterUpdate(JobCounter.OTHER_LOCAL_MAPS, 1);
   eventHandler.handle(jce);
  }
  eventHandler.handle(new TaskAttemptContainerAssignedEvent(
    event.getAttemptID(), container, applicationACLs));
 }
}

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

ContainerId containerId = ContainerId.newContainerId(appAttemptId, 0);
masterContainer.setId(containerId);
masterContainer.setNodeHttpAddress("node:port");
final String user = newUserName();
final String name = newAppName();

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

ContainerId containerId = ContainerId.newContainerId(appAttemptId, 0);
masterContainer.setId(containerId);
masterContainer.setNodeHttpAddress("node:port");
final String user = newUserName();
final String name = newAppName();

内容来源于网络，如有侵权，请联系作者删除！

Container

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com