All Superinterfaces:
org.apache.hadoop.yarn.event.EventHandler<ContainerEvent>
All Known Implementing Classes:
ContainerImpl

public interface Container extends org.apache.hadoop.yarn.event.EventHandler<ContainerEvent>
  • Method Details

    • getContainerId

      org.apache.hadoop.yarn.api.records.ContainerId getContainerId()
    • getContainerStartTime

      long getContainerStartTime()
      The timestamp when the container start request is received.
    • getContainerLaunchTime

      long getContainerLaunchTime()
      The timestamp when the container is allowed to be launched.
    • getResource

      org.apache.hadoop.yarn.api.records.Resource getResource()
    • getContainerTokenIdentifier

      org.apache.hadoop.yarn.security.ContainerTokenIdentifier getContainerTokenIdentifier()
    • setContainerTokenIdentifier

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

      String getUser()
    • getContainerState

      ContainerState getContainerState()
    • getLaunchContext

      org.apache.hadoop.yarn.api.records.ContainerLaunchContext getLaunchContext()
    • getCredentials

      org.apache.hadoop.security.Credentials getCredentials()
    • getLocalizedResources

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

      org.apache.hadoop.yarn.api.records.ContainerStatus cloneAndGetContainerStatus()
    • getNMContainerStatus

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

      boolean isRetryContextSet()
    • shouldRetry

      boolean shouldRetry(int errorCode)
    • getWorkDir

      String getWorkDir()
    • setWorkDir

      void setWorkDir(String workDir)
    • getCsiVolumesRootDir

      String getCsiVolumesRootDir()
    • setCsiVolumesRootDir

      void setCsiVolumesRootDir(String volumesRootDir)
    • getLogDir

      String getLogDir()
    • setLogDir

      void setLogDir(String logDir)
    • setIpAndHost

      void setIpAndHost(String[] ipAndHost)
    • setExposedPorts

      void setExposedPorts(String ports)
    • toString

      String toString()
      Overrides:
      toString in class Object
    • getPriority

      org.apache.hadoop.yarn.api.records.Priority getPriority()
    • getResourceSet

      ResourceSet getResourceSet()
    • isRunning

      boolean isRunning()
    • setIsReInitializing

      void setIsReInitializing(boolean isReInitializing)
    • isReInitializing

      boolean isReInitializing()
    • isMarkedForKilling

      boolean isMarkedForKilling()
    • canRollback

      boolean canRollback()
    • commitUpgrade

      void commitUpgrade()
    • sendLaunchEvent

      void sendLaunchEvent()
    • sendKillEvent

      void sendKillEvent(int exitStatus, String description)
    • isRecovering

      boolean isRecovering()
    • setContainerRuntimeData

      void setContainerRuntimeData(Object containerRuntimeData)
    • getContainerRuntimeData

      <T> T getContainerRuntimeData(Class<T> runtimeClazz) throws ContainerExecutionException
      Throws:
      ContainerExecutionException
    • getResourceMappings

      ResourceMappings getResourceMappings()
      Get assigned resource mappings to the container.
      Returns:
      Resource Mappings of the container
    • sendPauseEvent

      void sendPauseEvent(String description)
    • isContainerInFinalStates

      boolean isContainerInFinalStates()
      Verify container is in final states.
      Returns:
      true/false based on container's state
    • getLocalizationStatuses

      List<org.apache.hadoop.yarn.api.records.LocalizationStatus> getLocalizationStatuses()
      Get the localization statuses.
      Returns:
      localization statuses.
    • localizationCountersAsString

      String localizationCountersAsString()
      Vector of localization counters to be passed from NM to application container via environment variable $LOCALIZATION_COUNTERS. See ApplicationConstants.Environment.LOCALIZATION_COUNTERS
      Returns:
      coma-separated counter values