@InterfaceAudience.Private @InterfaceStability.Unstable public class MRAMSimulator extends AMSimulator
Modifier and Type | Field and Description |
---|---|
org.apache.log4j.Logger |
LOG |
amtype, appAttemptId, appId, finishedContainers, isTracked, oldAppId, queue, recordFactory, RESPONSE_ID, responseQueue, rm, se, simulateFinishTimeMS, simulateStartTimeMS, totalContainers, traceFinishTimeMS, traceStartTimeMS, user
Constructor and Description |
---|
MRAMSimulator() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkStop() |
void |
firstStep()
register with RM
|
void |
init(int id,
int heartbeatInterval,
List<ContainerSimulator> containerList,
org.apache.hadoop.yarn.server.resourcemanager.ResourceManager rm,
SLSRunner se,
long traceStartTime,
long traceFinishTime,
String user,
String queue,
boolean isTracked,
String oldAppId) |
void |
lastStep() |
protected void |
processResponseQueue() |
protected void |
requestAMContainer()
send out request for AM container
|
protected void |
sendContainerRequest() |
createAllocateRequest, createAllocateRequest, createResourceRequest, getAMType, getDuration, getNumTasks, getQueue, middleStep, packageRequests, untrackApp
compareTo, getDelay, init, init, run, setEndTime
public void init(int id, int heartbeatInterval, List<ContainerSimulator> containerList, org.apache.hadoop.yarn.server.resourcemanager.ResourceManager rm, SLSRunner se, long traceStartTime, long traceFinishTime, String user, String queue, boolean isTracked, String oldAppId)
init
in class AMSimulator
public void firstStep() throws Exception
AMSimulator
firstStep
in class AMSimulator
Exception
protected void requestAMContainer() throws org.apache.hadoop.yarn.exceptions.YarnException, IOException, InterruptedException
org.apache.hadoop.yarn.exceptions.YarnException
IOException
InterruptedException
protected void processResponseQueue() throws InterruptedException, org.apache.hadoop.yarn.exceptions.YarnException, IOException
processResponseQueue
in class AMSimulator
InterruptedException
org.apache.hadoop.yarn.exceptions.YarnException
IOException
protected void sendContainerRequest() throws org.apache.hadoop.yarn.exceptions.YarnException, IOException, InterruptedException
sendContainerRequest
in class AMSimulator
org.apache.hadoop.yarn.exceptions.YarnException
IOException
InterruptedException
protected void checkStop()
checkStop
in class AMSimulator
public void lastStep() throws Exception
lastStep
in class AMSimulator
Exception
Copyright © 2018 Apache Software Foundation. All Rights Reserved.