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, Comparable<RMContainer>

Constructor Summary

Constructors

Constructor and Description
RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container, 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.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.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId, String user, RMContext rmContext, String nodeLabelExpression)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelIncreaseReservation()
int	compareTo(RMContainer o)
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.Priority	getAllocatedPriority()
org.apache.hadoop.yarn.api.records.Resource	getAllocatedResource()
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()
org.apache.hadoop.yarn.api.records.ContainerState	getContainerState()
long	getCreationTime()
String	getDiagnosticsInfo()
org.apache.hadoop.yarn.api.records.ContainerStatus	getFinishedStatus()
long	getFinishTime()
org.apache.hadoop.yarn.api.records.Resource	getLastConfirmedResource()
String	getLogURL()
String	getNodeHttpAddress()
String	getNodeLabelExpression()
String	getQueueName()
org.apache.hadoop.yarn.api.records.NodeId	getReservedNode()
org.apache.hadoop.yarn.api.records.Priority	getReservedPriority()
org.apache.hadoop.yarn.api.records.Resource	getReservedResource()
List<org.apache.hadoop.yarn.api.records.ResourceRequest>	getResourceRequests()
RMContainerState	getState()
void	handle(RMContainerEvent event)
int	hashCode()
boolean	hasIncreaseReservation()
boolean	isAMContainer()
void	setAMContainer(boolean isAMContainer)
void	setQueueName(String queueName)
void	setResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> requests)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RMContainerImpl

public RMContainerImpl(org.apache.hadoop.yarn.api.records.Container container,
               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.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.api.records.ApplicationAttemptId appAttemptId,
               org.apache.hadoop.yarn.api.records.NodeId nodeId,
               String user,
               RMContext rmContext,
               long creationTime,
               String nodeLabelExpression)

Method Detail

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

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

getReservedPriority

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

Specified by:

getReservedPriority 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

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

getResourceRequests

public List<org.apache.hadoop.yarn.api.records.ResourceRequest> getResourceRequests()

Specified by:

getResourceRequests in interface RMContainer

setResourceRequests

public void setResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> requests)

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>

getFinishedStatus

public org.apache.hadoop.yarn.api.records.ContainerStatus getFinishedStatus()

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

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>

hasIncreaseReservation

public boolean hasIncreaseReservation()

Specified by:

hasIncreaseReservation in interface RMContainer

cancelIncreaseReservation

public void cancelIncreaseReservation()

Specified by:

cancelIncreaseReservation in interface RMContainer

setQueueName

public void setQueueName(String queueName)

getQueueName

public String getQueueName()

Specified by:

getQueueName in interface RMContainer