Package org.apache.hadoop.mapreduce.v2.app.rm.preemption

Class AMPreemptionPolicy.Context

java.lang.Object
org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy.Context
Enclosing interface:
AMPreemptionPolicy
public abstract static class AMPreemptionPolicy.Context extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    Context()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract List<org.apache.hadoop.yarn.api.records.Container>
    getContainers(org.apache.hadoop.mapreduce.v2.api.records.TaskType t)
    Method provides the complete list of containers running task of type t for this AM.
    abstract org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId
    getTaskAttempt(org.apache.hadoop.yarn.api.records.ContainerId container)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • Context

      public Context()

  • Method Details

    • getTaskAttempt

      public abstract org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId getTaskAttempt(org.apache.hadoop.yarn.api.records.ContainerId container)
      Parameters:
      container - ID of container to preempt
      Returns:
      Task associated with the running container or null if no task is bound to that container.

    • getContainers

      public abstract List<org.apache.hadoop.yarn.api.records.Container> getContainers(org.apache.hadoop.mapreduce.v2.api.records.TaskType t)
      Method provides the complete list of containers running task of type t for this AM.
      Parameters:
      t - the type of containers
      Returns:
      a map containing