public interface Container extends org.apache.hadoop.yarn.event.EventHandler<ContainerEvent>
Modifier and Type | Method and Description |
---|---|
boolean |
canRollback() |
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> runtimeClazz) |
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.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() |
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() |
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() |
org.apache.hadoop.yarn.api.records.ContainerId getContainerId()
long getContainerStartTime()
long getContainerLaunchTime()
org.apache.hadoop.yarn.api.records.Resource getResource()
org.apache.hadoop.yarn.security.ContainerTokenIdentifier getContainerTokenIdentifier()
void setContainerTokenIdentifier(org.apache.hadoop.yarn.security.ContainerTokenIdentifier token)
String getUser()
ContainerState getContainerState()
org.apache.hadoop.yarn.api.records.ContainerLaunchContext getLaunchContext()
org.apache.hadoop.security.Credentials getCredentials()
org.apache.hadoop.yarn.api.records.ContainerStatus cloneAndGetContainerStatus()
org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus getNMContainerStatus()
boolean isRetryContextSet()
boolean shouldRetry(int errorCode)
String getWorkDir()
void setWorkDir(String workDir)
String getCsiVolumesRootDir()
void setCsiVolumesRootDir(String volumesRootDir)
String getLogDir()
void setLogDir(String logDir)
void setIpAndHost(String[] ipAndHost)
void setExposedPorts(String ports)
org.apache.hadoop.yarn.api.records.Priority getPriority()
ResourceSet getResourceSet()
boolean isRunning()
void setIsReInitializing(boolean isReInitializing)
boolean isReInitializing()
boolean isMarkedForKilling()
boolean canRollback()
void commitUpgrade()
void sendLaunchEvent()
void sendKillEvent(int exitStatus, String description)
boolean isRecovering()
void setContainerRuntimeData(Object containerRuntimeData)
<T> T getContainerRuntimeData(Class<T> runtimeClazz) throws ContainerExecutionException
ContainerExecutionException
ResourceMappings getResourceMappings()
void sendPauseEvent(String description)
boolean isContainerInFinalStates()
List<org.apache.hadoop.yarn.api.records.LocalizationStatus> getLocalizationStatuses()
String localizationCountersAsString()
$LOCALIZATION_COUNTERS
. See
ApplicationConstants.Environment.LOCALIZATION_COUNTERS
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.