org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator

Class RegularContainerAllocator

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator.AbstractContainerAllocator

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator.RegularContainerAllocator

public class RegularContainerAllocator
extends AbstractContainerAllocator

Allocate normal (new) containers, considers locality/label, etc. Using delayed scheduling mechanism to get better locality allocation.

Constructor Summary

Constructors

Constructor and Description
RegularContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext)

Method Summary

Methods

Modifier and Type	Method and Description
CSAssignment	assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerNode node, SchedulingMode schedulingMode, ResourceLimits resourceLimits, RMContainer reservedContainer) allocate needs to handle following stuffs: Select request: Select a request to allocate.
float	getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority, int clusterNodes)

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator.AbstractContainerAllocator

getCSAssignmentFromAllocateResult

Methods inherited from class java.lang.Object

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

Constructor Detail

RegularContainerAllocator

public RegularContainerAllocator(FiCaSchedulerApp application,
                         org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
                         RMContext rmContext)

Method Detail

getLocalityWaitFactor

public float getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority,
                          int clusterNodes)

assignContainers

public CSAssignment assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource,
                            FiCaSchedulerNode node,
                            SchedulingMode schedulingMode,
                            ResourceLimits resourceLimits,
                            RMContainer reservedContainer)

Description copied from class: AbstractContainerAllocator

allocate needs to handle following stuffs:

• Select request: Select a request to allocate. E.g. select a resource request based on requirement/priority/locality.
• Check if a given resource can be allocated based on resource availability
• Do allocation: this will decide/create allocated/reserved container, this will also update metrics

Specified by:

assignContainers in class AbstractContainerAllocator