Package org.apache.hadoop.yarn.server.resourcemanager.rmcontainer

Class RMContainerImpl

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.rmcontainer.RMContainerImpl

All Implemented Interfaces:

Comparable<RMContainer>, org.apache.hadoop.yarn.event.EventHandler<RMContainerEvent>, RMContainer

public class RMContainerImpl
extends Object
implements RMContainer

Constructor Summary

Constructors

Constructor	Description
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext)
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext, boolean isExternallyAllocated)
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext, long creationTime, String nodeLabelExpression)
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext, long creationTime, String nodeLabelExpression, boolean isExternallyAllocated)
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext, String nodeLabelExpression)

Method Summary

Modifier and Type	Method	Description
int	compareTo(RMContainer o)
boolean	completed()
org.apache.hadoop.yarn.api.records.ContainerReport	createContainerReport()
boolean	equals(Object obj)
org.apache.hadoop.yarn.api.records.NodeId	getAllocatedNode()
org.apache.hadoop.yarn.api.records.Resource	getAllocatedOrReservedResource()
org.apache.hadoop.yarn.api.records.Priority	getAllocatedPriority()
org.apache.hadoop.yarn.api.records.Resource	getAllocatedResource()
org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey	getAllocatedSchedulerKey()
Set<String>	getAllocationTags()	Return SchedulingRequest.getAllocationTags() specified by AM.
org.apache.hadoop.yarn.api.records.ApplicationAttemptId	getApplicationAttemptId()
org.apache.hadoop.yarn.api.records.Container	getContainer()
int	getContainerExitStatus()
org.apache.hadoop.yarn.api.records.ContainerId	getContainerId()
ContainerRequest	getContainerRequest()
org.apache.hadoop.yarn.api.records.ContainerState	getContainerState()
long	getCreationTime()
String	getDiagnosticsInfo()
org.apache.hadoop.yarn.api.records.ExecutionType	getExecutionType()
Map<String,List<Map<String,String>>>	getExposedPorts()
long	getFinishTime()
org.apache.hadoop.yarn.api.records.Resource	getLastConfirmedResource()
String	getLogURL()
String	getNodeHttpAddress()
org.apache.hadoop.yarn.api.records.NodeId	getNodeId()
String	getNodeLabelExpression()
String	getQueueName()
org.apache.hadoop.yarn.api.records.NodeId	getReservedNode()
org.apache.hadoop.yarn.api.records.Resource	getReservedResource()
org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey	getReservedSchedulerKey()
RMContainerState	getState()
void	handle(RMContainerEvent event)
int	hashCode()
boolean	isAMContainer()
boolean	isRemotelyAllocated()	If the container was allocated by a container other than the Resource Manager (e.g., the distributed scheduler in the NM LocalScheduler).
protected void	onInvalidStateTransition(RMContainerEventType rmContainerEventType, RMContainerState state)	catch the InvalidStateTransition.
void	setAllocationTags(Set<String> tags)
void	setAMContainer(boolean isAMContainer)
void	setContainer(org.apache.hadoop.yarn.api.records.Container container)
void	setContainerId(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	setContainerRequest(ContainerRequest request)
void	setExposedPorts(Map<String,List<Map<String,String>>> ports)
void	setQueueName(String queueName)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.NodeId nodeId,
 String user,
 RMContext rmContext)

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.NodeId nodeId,
 String user,
 RMContext rmContext,
 boolean isExternallyAllocated)

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.NodeId nodeId,
 String user,
 RMContext rmContext,
 String nodeLabelExpression)

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.NodeId nodeId,
 String user,
 RMContext rmContext,
 long creationTime,
 String nodeLabelExpression)

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.NodeId nodeId,
 String user,
 RMContext rmContext,
 long creationTime,
 String nodeLabelExpression,
 boolean isExternallyAllocated)

Method Details

getContainerId

public org.apache.hadoop.yarn.api.records.ContainerId getContainerId()

Specified by:

getContainerId in interface RMContainer

getApplicationAttemptId

public org.apache.hadoop.yarn.api.records.ApplicationAttemptId getApplicationAttemptId()

Specified by:

getApplicationAttemptId in interface RMContainer

getContainer

public org.apache.hadoop.yarn.api.records.Container getContainer()

Specified by:

getContainer in interface RMContainer

setContainer

public void setContainer(org.apache.hadoop.yarn.api.records.Container container)

getState

public RMContainerState getState()

Specified by:

getState in interface RMContainer

getReservedResource

public org.apache.hadoop.yarn.api.records.Resource getReservedResource()

Specified by:

getReservedResource in interface RMContainer

getReservedNode

public org.apache.hadoop.yarn.api.records.NodeId getReservedNode()

Specified by:

getReservedNode in interface RMContainer

getReservedSchedulerKey

public org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey getReservedSchedulerKey()

Specified by:

getReservedSchedulerKey in interface RMContainer

getAllocatedResource

public org.apache.hadoop.yarn.api.records.Resource getAllocatedResource()

Specified by:

getAllocatedResource in interface RMContainer

getLastConfirmedResource

public org.apache.hadoop.yarn.api.records.Resource getLastConfirmedResource()

Specified by:

getLastConfirmedResource in interface RMContainer

getAllocatedNode

public org.apache.hadoop.yarn.api.records.NodeId getAllocatedNode()

Specified by:

getAllocatedNode in interface RMContainer

getAllocatedSchedulerKey

public org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey getAllocatedSchedulerKey()

Specified by:

getAllocatedSchedulerKey in interface RMContainer

getAllocatedPriority

public org.apache.hadoop.yarn.api.records.Priority getAllocatedPriority()

Specified by:

getAllocatedPriority in interface RMContainer

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface RMContainer

getFinishTime

public long getFinishTime()

Specified by:

getFinishTime in interface RMContainer

getDiagnosticsInfo

public String getDiagnosticsInfo()

Specified by:

getDiagnosticsInfo in interface RMContainer

getLogURL

public String getLogURL()

Specified by:

getLogURL in interface RMContainer

getContainerExitStatus

public int getContainerExitStatus()

Specified by:

getContainerExitStatus in interface RMContainer

getContainerState

public org.apache.hadoop.yarn.api.records.ContainerState getContainerState()

Specified by:

getContainerState in interface RMContainer

getContainerRequest

public ContainerRequest getContainerRequest()

Specified by:

getContainerRequest in interface RMContainer

setContainerRequest

public void setContainerRequest(ContainerRequest request)

toString

public String toString()

Overrides:

toString in class Object

isAMContainer

public boolean isAMContainer()

Specified by:

isAMContainer in interface RMContainer

setAMContainer

public void setAMContainer(boolean isAMContainer)

handle

public void handle(RMContainerEvent event)

Specified by:

handle in interface org.apache.hadoop.yarn.event.EventHandler<RMContainerEvent>

completed

public boolean completed()

Specified by:

completed in interface RMContainer

getNodeId

public org.apache.hadoop.yarn.api.records.NodeId getNodeId()

Specified by:

getNodeId in interface RMContainer

getAllocationTags

public Set<String> getAllocationTags()

Description copied from interface: RMContainer

Return SchedulingRequest.getAllocationTags() specified by AM.

Specified by:

getAllocationTags in interface RMContainer

Returns:

allocation tags, could be null/empty

setAllocationTags

public void setAllocationTags(Set<String> tags)

createContainerReport

public org.apache.hadoop.yarn.api.records.ContainerReport createContainerReport()

Specified by:

createContainerReport in interface RMContainer

getNodeHttpAddress

public String getNodeHttpAddress()

Specified by:

getNodeHttpAddress in interface RMContainer

getExposedPorts

public Map<String,List<Map<String,String>>> getExposedPorts()

Specified by:

getExposedPorts in interface RMContainer

setExposedPorts

public void setExposedPorts(Map<String,List<Map<String,String>>> ports)

Specified by:

setExposedPorts in interface RMContainer

getNodeLabelExpression

public String getNodeLabelExpression()

Specified by:

getNodeLabelExpression in interface RMContainer

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

compareTo

public int compareTo(RMContainer o)

Specified by:

compareTo in interface Comparable<RMContainer>

setQueueName

public void setQueueName(String queueName)

getQueueName

public String getQueueName()

Specified by:

getQueueName in interface RMContainer

getExecutionType

public org.apache.hadoop.yarn.api.records.ExecutionType getExecutionType()

Specified by:

getExecutionType in interface RMContainer

isRemotelyAllocated

public boolean isRemotelyAllocated()

Description copied from interface: RMContainer

If the container was allocated by a container other than the Resource Manager (e.g., the distributed scheduler in the NM LocalScheduler).

Specified by:

isRemotelyAllocated in interface RMContainer

Returns:

If the container was allocated remotely.

getAllocatedOrReservedResource

public org.apache.hadoop.yarn.api.records.Resource getAllocatedOrReservedResource()

Specified by:

getAllocatedOrReservedResource in interface RMContainer

setContainerId

public void setContainerId(org.apache.hadoop.yarn.api.records.ContainerId containerId)

Specified by:

setContainerId in interface RMContainer

onInvalidStateTransition

@VisibleForTesting
protected void onInvalidStateTransition(RMContainerEventType rmContainerEventType,
 RMContainerState state)

catch the InvalidStateTransition.

Parameters:

state - RMContainerState.

rmContainerEventType - RMContainerEventType.