Package org.apache.hadoop.yarn.server.api.protocolrecords

Class DistributedSchedulingAllocateRequest

java.lang.Object
org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest
Direct Known Subclasses:
DistributedSchedulingAllocateRequestPBImpl
@Public @Evolving public abstract class DistributedSchedulingAllocateRequest extends Object
Object used by the Application Master when distributed scheduling is enabled, in order to forward the AllocateRequest for GUARANTEED containers to the Resource Manager, and to notify the Resource Manager about the allocation of OPPORTUNISTIC containers through the Distributed Scheduler.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DistributedSchedulingAllocateRequest()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract List<org.apache.hadoop.yarn.api.records.Container>
    getAllocatedContainers()
    Get the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.
    abstract org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest
    getAllocateRequest()
    Get the underlying AllocateRequest object.
    abstract void
    setAllocatedContainers(List<org.apache.hadoop.yarn.api.records.Container> containers)
    Set the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.
    abstract void
    setAllocateRequest(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest allocateRequest)
    Set the underlying AllocateRequest object.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DistributedSchedulingAllocateRequest

      public DistributedSchedulingAllocateRequest()

  • Method Details

    • getAllocateRequest

      @Public @Evolving public abstract org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest getAllocateRequest()
      Get the underlying AllocateRequest object.
      Returns:
      Allocate request

    • setAllocateRequest

      @Public @Evolving public abstract void setAllocateRequest(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest allocateRequest)
      Set the underlying AllocateRequest object.
      Parameters:
      allocateRequest - Allocate request

    • getAllocatedContainers

      @Public @Evolving public abstract List<org.apache.hadoop.yarn.api.records.Container> getAllocatedContainers()
      Get the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.
      Returns:
      list of newly allocated Container

    • setAllocatedContainers

      @Public @Evolving public abstract void setAllocatedContainers(List<org.apache.hadoop.yarn.api.records.Container> containers)
      Set the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.
      Parameters:
      containers - list of newly allocated Container