Package org.apache.hadoop.yarn.server.nodemanager.containermanager.container

Class ContainerImpl

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerImpl

All Implemented Interfaces:

org.apache.hadoop.yarn.event.EventHandler<ContainerEvent>, Container

public class ContainerImpl
extends Object
implements Container

Constructor Summary

Constructors

Constructor	Description
ContainerImpl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.event.Dispatcher dispatcher, org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext, org.apache.hadoop.security.Credentials creds, NodeManagerMetrics metrics, org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier, Context context)
ContainerImpl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.event.Dispatcher dispatcher, org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext, org.apache.hadoop.security.Credentials creds, NodeManagerMetrics metrics, org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier, Context context, long startTs)
ContainerImpl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.event.Dispatcher dispatcher, org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext, org.apache.hadoop.security.Credentials creds, NodeManagerMetrics metrics, org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier, Context context, NMStateStoreService.RecoveredContainerState rcs)

Method Summary

Modifier and Type	Method	Description
boolean	canRollback()
void	cleanup()
org.apache.hadoop.yarn.api.records.ContainerStatus	cloneAndGetContainerStatus()
void	commitUpgrade()
org.apache.hadoop.yarn.api.records.ContainerId	getContainerId()
long	getContainerLaunchTime()	The timestamp when the container is allowed to be launched.
<T> T	getContainerRuntimeData(Class<T> runtimeClass)
long	getContainerStartTime()	The timestamp when the container start request is received.
ContainerState	getContainerState()
org.apache.hadoop.yarn.security.ContainerTokenIdentifier	getContainerTokenIdentifier()
org.apache.hadoop.security.Credentials	getCredentials()
String	getCsiVolumesRootDir()
org.apache.hadoop.yarn.api.records.ContainerState	getCurrentState()
org.apache.hadoop.yarn.api.records.ContainerLaunchContext	getLaunchContext()
List<org.apache.hadoop.yarn.api.records.LocalizationStatus>	getLocalizationStatuses()	Get the localization statuses.
Map<org.apache.hadoop.fs.Path,List<String>>	getLocalizedResources()
String	getLogDir()
org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus	getNMContainerStatus()
NMTimelinePublisher	getNMTimelinePublisher()
org.apache.hadoop.yarn.api.records.Priority	getPriority()
org.apache.hadoop.yarn.api.records.Resource	getResource()
ResourceMappings	getResourceMappings()	Get assigned resource mappings to the container.
ResourceSet	getResourceSet()
String	getUser()
String	getWorkDir()
void	handle(ContainerEvent event)
boolean	isContainerInFinalStates()	Verify container is in final states.
boolean	isMarkedForKilling()
boolean	isRecovering()
boolean	isReInitializing()
boolean	isRetryContextSet()
boolean	isRunning()
String	localizationCountersAsString()	Vector of localization counters to be passed from NM to application container via environment variable $LOCALIZATION_COUNTERS.
void	sendKillEvent(int exitStatus, String description)
void	sendLaunchEvent()
void	sendPauseEvent(String description)
void	setContainerRuntimeData(Object containerRuntimeData)
void	setContainerTokenIdentifier(org.apache.hadoop.yarn.security.ContainerTokenIdentifier token)
void	setCsiVolumesRootDir(String volumesRootDir)
void	setExposedPorts(String ports)
void	setIpAndHost(String[] ipAndHost)
void	setIsReInitializing(boolean isReInitializing)
void	setLogDir(String logDir)
void	setWorkDir(String workDir)
boolean	shouldRetry(int errorCode)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ContainerImpl

public ContainerImpl(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext,
 org.apache.hadoop.security.Credentials creds,
 NodeManagerMetrics metrics,
 org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier,
 Context context)

ContainerImpl

public ContainerImpl(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext,
 org.apache.hadoop.security.Credentials creds,
 NodeManagerMetrics metrics,
 org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier,
 Context context,
 long startTs)

ContainerImpl

public ContainerImpl(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 org.apache.hadoop.yarn.api.records.ContainerLaunchContext launchContext,
 org.apache.hadoop.security.Credentials creds,
 NodeManagerMetrics metrics,
 org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier,
 Context context,
 NMStateStoreService.RecoveredContainerState rcs)

Method Details

getCurrentState

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

getNMTimelinePublisher

public NMTimelinePublisher getNMTimelinePublisher()

getUser

public String getUser()

Specified by:

getUser in interface Container

getLocalizedResources

public Map<org.apache.hadoop.fs.Path,List<String>> getLocalizedResources()

Specified by:

getLocalizedResources in interface Container

getCredentials

public org.apache.hadoop.security.Credentials getCredentials()

Specified by:

getCredentials in interface Container

getContainerState

public ContainerState getContainerState()

Specified by:

getContainerState in interface Container

getLaunchContext

public org.apache.hadoop.yarn.api.records.ContainerLaunchContext getLaunchContext()

Specified by:

getLaunchContext in interface Container

cloneAndGetContainerStatus

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

Specified by:

cloneAndGetContainerStatus in interface Container

getNMContainerStatus

public org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus getNMContainerStatus()

Specified by:

getNMContainerStatus in interface Container

getContainerId

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

Specified by:

getContainerId in interface Container

getContainerStartTime

public long getContainerStartTime()

Description copied from interface: Container

The timestamp when the container start request is received.

Specified by:

getContainerStartTime in interface Container

getContainerLaunchTime

public long getContainerLaunchTime()

Description copied from interface: Container

The timestamp when the container is allowed to be launched.

Specified by:

getContainerLaunchTime in interface Container

getResource

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

Specified by:

getResource in interface Container

getContainerTokenIdentifier

public org.apache.hadoop.yarn.security.ContainerTokenIdentifier getContainerTokenIdentifier()

Specified by:

getContainerTokenIdentifier in interface Container

setContainerTokenIdentifier

public void setContainerTokenIdentifier(org.apache.hadoop.yarn.security.ContainerTokenIdentifier token)

Specified by:

setContainerTokenIdentifier in interface Container

getWorkDir

public String getWorkDir()

Specified by:

getWorkDir in interface Container

setWorkDir

public void setWorkDir(String workDir)

Specified by:

setWorkDir in interface Container

getCsiVolumesRootDir

public String getCsiVolumesRootDir()

Specified by:

getCsiVolumesRootDir in interface Container

setCsiVolumesRootDir

public void setCsiVolumesRootDir(String volumesRootDir)

Specified by:

setCsiVolumesRootDir in interface Container

setIpAndHost

public void setIpAndHost(String[] ipAndHost)

Specified by:

setIpAndHost in interface Container

getLogDir

public String getLogDir()

Specified by:

getLogDir in interface Container

setLogDir

public void setLogDir(String logDir)

Specified by:

setLogDir in interface Container

getResourceSet

public ResourceSet getResourceSet()

Specified by:

getResourceSet in interface Container

sendLaunchEvent

public void sendLaunchEvent()

Specified by:

sendLaunchEvent in interface Container

sendKillEvent

public void sendKillEvent(int exitStatus,
 String description)

Specified by:

sendKillEvent in interface Container

sendPauseEvent

public void sendPauseEvent(String description)

Specified by:

sendPauseEvent in interface Container

cleanup

public void cleanup()

isRetryContextSet

public boolean isRetryContextSet()

Specified by:

isRetryContextSet in interface Container

shouldRetry

public boolean shouldRetry(int errorCode)

Specified by:

shouldRetry in interface Container

handle

public void handle(ContainerEvent event)

Specified by:

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

toString

public String toString()

Specified by:

toString in interface Container

Overrides:

toString in class Object

getPriority

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

Specified by:

getPriority in interface Container

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Container

setIsReInitializing

public void setIsReInitializing(boolean isReInitializing)

Specified by:

setIsReInitializing in interface Container

isReInitializing

public boolean isReInitializing()

Specified by:

isReInitializing in interface Container

isMarkedForKilling

public boolean isMarkedForKilling()

Specified by:

isMarkedForKilling in interface Container

canRollback

public boolean canRollback()

Specified by:

canRollback in interface Container

commitUpgrade

public void commitUpgrade()

Specified by:

commitUpgrade in interface Container

isRecovering

public boolean isRecovering()

Specified by:

isRecovering in interface Container

getResourceMappings

public ResourceMappings getResourceMappings()

Get assigned resource mappings to the container.

Specified by:

getResourceMappings in interface Container

Returns:

Resource Mappings of the container

isContainerInFinalStates

public boolean isContainerInFinalStates()

Description copied from interface: Container

Verify container is in final states.

Specified by:

isContainerInFinalStates in interface Container

Returns:

true/false based on container's state

setExposedPorts

public void setExposedPorts(String ports)

Specified by:

setExposedPorts in interface Container

getLocalizationStatuses

public List<org.apache.hadoop.yarn.api.records.LocalizationStatus> getLocalizationStatuses()

Description copied from interface: Container

Get the localization statuses.

Specified by:

getLocalizationStatuses in interface Container

Returns:

localization statuses.

setContainerRuntimeData

public void setContainerRuntimeData(Object containerRuntimeData)

Specified by:

setContainerRuntimeData in interface Container

getContainerRuntimeData

public <T> T getContainerRuntimeData(Class<T> runtimeClass)
                              throws ContainerExecutionException

Specified by:

getContainerRuntimeData in interface Container

Throws:

ContainerExecutionException

localizationCountersAsString

public String localizationCountersAsString()

Description copied from interface: Container

Vector of localization counters to be passed from NM to application container via environment variable $LOCALIZATION_COUNTERS. See ApplicationConstants.Environment.LOCALIZATION_COUNTERS

Specified by:

localizationCountersAsString in interface Container

Returns:

coma-separated counter values