@InterfaceAudience.Private @InterfaceStability.Unstable public class NMSimulator extends TaskRunner.Task
Constructor and Description |
---|
NMSimulator() |
Modifier and Type | Method and Description |
---|---|
void |
addNewContainer(org.apache.hadoop.yarn.api.records.Container container,
long lifeTimeMS)
launch a new container with the given life time
|
void |
cleanupContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
clean up an AM container and add to completed list
|
void |
firstStep() |
org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode |
getNode() |
void |
init(String nodeIdStr,
int memory,
int cores,
double disks,
int dispatchTime,
int heartBeatInterval,
org.apache.hadoop.yarn.server.resourcemanager.ResourceManager rm) |
void |
lastStep() |
void |
middleStep() |
compareTo, getDelay, init, init, run, setEndTime
public void init(String nodeIdStr, int memory, int cores, double disks, int dispatchTime, int heartBeatInterval, org.apache.hadoop.yarn.server.resourcemanager.ResourceManager rm) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
public void firstStep()
firstStep
in class TaskRunner.Task
public void middleStep() throws Exception
middleStep
in class TaskRunner.Task
Exception
public void lastStep()
lastStep
in class TaskRunner.Task
public org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode getNode()
public void addNewContainer(org.apache.hadoop.yarn.api.records.Container container, long lifeTimeMS)
public void cleanupContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
containerId
- id of the container to be cleanedCopyright © 2018 Apache Software Foundation. All Rights Reserved.