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

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

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

Container.setResource介绍

暂无

代码示例

代码示例来源: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: 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: 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: 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-yarn-server-common

? rr.getResourceName() : "dummy", 1000);
container.setNodeId(nodeId);
container.setResource(rr.getCapability());
containerList.add(container);

代码示例来源: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

newContainer.setVersion(existingRMContainer.getContainer().getVersion());
tempRMContainer.getContainer().setResource(resourceToRelease);
tempRMContainer.getContainer().setExecutionType(
  existingRMContainer.getContainer().getExecutionType());

相关文章