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

Class QueueManagementDynamicEditPolicy

java.lang.Object

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

All Implemented Interfaces:

SchedulingEditPolicy

public class QueueManagementDynamicEditPolicy
extends Object
implements SchedulingEditPolicy

Queue Management scheduling policy for managed parent queues which enable auto child queue creation

Constructor Summary

Constructors

Constructor	Description
QueueManagementDynamicEditPolicy()	Instantiated by CapacitySchedulerConfiguration
QueueManagementDynamicEditPolicy(RMContext context, CapacityScheduler scheduler)
QueueManagementDynamicEditPolicy(RMContext context, CapacityScheduler scheduler, org.apache.hadoop.yarn.util.Clock clock)

Method Summary

Modifier and Type	Method	Description
void	editSchedule()	This method is invoked at regular intervals.
Set<String>	getManagedParentQueues()
long	getMonitoringInterval()
String	getPolicyName()
org.apache.hadoop.yarn.util.resource.ResourceCalculator	getRC()
org.apache.hadoop.yarn.util.resource.ResourceCalculator	getResourceCalculator()
RMContext	getRmContext()
CapacityScheduler	getScheduler()
void	init(org.apache.hadoop.conf.Configuration config, RMContext context, ResourceScheduler sched)
void	reinitialize(org.apache.hadoop.conf.Configuration config, RMContext context, ResourceScheduler sched)	Reinitializes queues(Called on scheduler.reinitialize)

Methods inherited from class java.lang.Object

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

Constructor Details

QueueManagementDynamicEditPolicy

public QueueManagementDynamicEditPolicy()

Instantiated by CapacitySchedulerConfiguration

QueueManagementDynamicEditPolicy

@VisibleForTesting
public QueueManagementDynamicEditPolicy(RMContext context,
 CapacityScheduler scheduler)

QueueManagementDynamicEditPolicy

@VisibleForTesting
public QueueManagementDynamicEditPolicy(RMContext context,
 CapacityScheduler scheduler,
 org.apache.hadoop.yarn.util.Clock clock)

Method Details

init

public void init(org.apache.hadoop.conf.Configuration config,
 RMContext context,
 ResourceScheduler sched)

Specified by:

init in interface SchedulingEditPolicy

reinitialize

public void reinitialize(org.apache.hadoop.conf.Configuration config,
 RMContext context,
 ResourceScheduler sched)

Reinitializes queues(Called on scheduler.reinitialize)

Parameters:

config - Configuration

context - The resourceManager's context

sched - The scheduler

editSchedule

public void editSchedule()

Description copied from interface: SchedulingEditPolicy

This method is invoked at regular intervals. Internally the policy is allowed to track containers and affect the scheduler. The "actions" performed are passed back through an EventHandler.

Specified by:

editSchedule in interface SchedulingEditPolicy

getMonitoringInterval

public long getMonitoringInterval()

Specified by:

getMonitoringInterval in interface SchedulingEditPolicy

getPolicyName

public String getPolicyName()

Specified by:

getPolicyName in interface SchedulingEditPolicy

getResourceCalculator

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

getRmContext

public RMContext getRmContext()

getRC

public org.apache.hadoop.yarn.util.resource.ResourceCalculator getRC()

getScheduler

public CapacityScheduler getScheduler()

getManagedParentQueues

public Set<String> getManagedParentQueues()