Package org.apache.hadoop.yarn.server.resourcemanager.reservation

Class CapacityReservationSystem

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.resourcemanager.reservation.AbstractReservationSystem

org.apache.hadoop.yarn.server.resourcemanager.reservation.CapacityReservationSystem

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, Recoverable, ReservationSystem

@LimitedPrivate("yarn")
@Unstable
public class CapacityReservationSystem
extends AbstractReservationSystem

This is the implementation of ReservationSystem based on the CapacityScheduler

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.reservation.AbstractReservationSystem

conf, planStepSize

Constructor Summary

Constructors

Constructor	Description
CapacityReservationSystem()

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.yarn.api.records.Resource	getMaxAllocation()
protected org.apache.hadoop.yarn.api.records.Resource	getMinAllocation()
Plan	getPlan(String planName)	Get an existing Plan that has been initialized.
protected org.apache.hadoop.yarn.api.records.Resource	getPlanQueueCapacity(String planQueueName)
protected String	getPlanQueuePath(String planQueueName)
protected ReservationSchedulerConfiguration	getReservationSchedulerConfiguration()
protected org.apache.hadoop.yarn.util.resource.ResourceCalculator	getResourceCalculator()
protected QueueMetrics	getRootQueueMetrics()
void	reinitialize(org.apache.hadoop.conf.Configuration conf, RMContext rmContext)	Re-initialize the ReservationSystem.

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.reservation.AbstractReservationSystem

getAdmissionPolicy, getAgent, getAllPlans, getDefaultReservationSystem, getNewReservationId, getPlanFollowerTimeStep, getQueueForReservation, getReplanner, getReservationsACLsManager, initializePlan, recover, serviceInit, serviceStart, serviceStop, setQueueForReservation, setRMContext, synchronizePlan

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Constructor Details

CapacityReservationSystem

public CapacityReservationSystem()

Method Details

reinitialize

public void reinitialize(org.apache.hadoop.conf.Configuration conf,
 RMContext rmContext)
                  throws org.apache.hadoop.yarn.exceptions.YarnException

Description copied from interface: ReservationSystem

Re-initialize the ReservationSystem.

Specified by:

reinitialize in interface ReservationSystem

Overrides:

reinitialize in class AbstractReservationSystem

Parameters:

conf - configuration

rmContext - current context of the ResourceManager

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - if initialization of the configured plan fails

getMinAllocation

protected org.apache.hadoop.yarn.api.records.Resource getMinAllocation()

Specified by:

getMinAllocation in class AbstractReservationSystem

getMaxAllocation

protected org.apache.hadoop.yarn.api.records.Resource getMaxAllocation()

Specified by:

getMaxAllocation in class AbstractReservationSystem

getResourceCalculator

protected org.apache.hadoop.yarn.util.resource.ResourceCalculator getResourceCalculator()

Specified by:

getResourceCalculator in class AbstractReservationSystem

getRootQueueMetrics

protected QueueMetrics getRootQueueMetrics()

Specified by:

getRootQueueMetrics in class AbstractReservationSystem

getPlanQueuePath

protected String getPlanQueuePath(String planQueueName)

Specified by:

getPlanQueuePath in class AbstractReservationSystem

getPlanQueueCapacity

protected org.apache.hadoop.yarn.api.records.Resource getPlanQueueCapacity(String planQueueName)

Specified by:

getPlanQueueCapacity in class AbstractReservationSystem

getPlan

public Plan getPlan(String planName)

Description copied from interface: ReservationSystem

Get an existing Plan that has been initialized.

Specified by:

getPlan in interface ReservationSystem

Overrides:

getPlan in class AbstractReservationSystem

Parameters:

planName - the name of the Plan

Returns:

the Plan identified by name

getReservationSchedulerConfiguration

protected ReservationSchedulerConfiguration getReservationSchedulerConfiguration()

Specified by:

getReservationSchedulerConfiguration in class AbstractReservationSystem