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

Class QueuePlacementRuleUtils

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.placement.QueuePlacementRuleUtils

public final class QueuePlacementRuleUtils
extends Object

Utility class for Capacity Scheduler queue PlacementRules.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CURRENT_USER_MAPPING
static final String	PRIMARY_GROUP_MAPPING
static final String	SECONDARY_GROUP_MAPPING

Method Summary

Modifier and Type	Method	Description
static ApplicationPlacementContext	getPlacementContext(QueueMapping mapping, String leafQueueName, CapacitySchedulerQueueManager queueManager)
static ApplicationPlacementContext	getPlacementContext(QueueMapping mapping, CapacitySchedulerQueueManager queueManager)
static boolean	isStaticQueueMapping(QueueMapping mapping)
static QueueMapping	validateAndGetAutoCreatedQueueMapping(CapacitySchedulerQueueManager queueManager, QueueMapping mapping)
static QueueMapping	validateAndGetQueueMapping(CapacitySchedulerQueueManager queueManager, CSQueue queue, QueueMapping mapping)
static void	validateQueueMappingUnderParentQueue(CSQueue parentQueue, String parentQueueName, String leafQueuePath)

Methods inherited from class java.lang.Object

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

Field Details

CURRENT_USER_MAPPING

public static final String CURRENT_USER_MAPPING

See Also:

• Constant Field Values

PRIMARY_GROUP_MAPPING

public static final String PRIMARY_GROUP_MAPPING

See Also:

• Constant Field Values

SECONDARY_GROUP_MAPPING

public static final String SECONDARY_GROUP_MAPPING

See Also:

• Constant Field Values

Method Details

validateQueueMappingUnderParentQueue

public static void validateQueueMappingUnderParentQueue(CSQueue parentQueue,
 String parentQueueName,
 String leafQueuePath)
                                                 throws IOException

Throws:

IOException

validateAndGetAutoCreatedQueueMapping

public static QueueMapping validateAndGetAutoCreatedQueueMapping(CapacitySchedulerQueueManager queueManager,
 QueueMapping mapping)
                                                          throws IOException

Throws:

IOException

validateAndGetQueueMapping

public static QueueMapping validateAndGetQueueMapping(CapacitySchedulerQueueManager queueManager,
 CSQueue queue,
 QueueMapping mapping)
                                               throws IOException

Throws:

IOException

isStaticQueueMapping

public static boolean isStaticQueueMapping(QueueMapping mapping)

getPlacementContext

public static ApplicationPlacementContext getPlacementContext(QueueMapping mapping,
 CapacitySchedulerQueueManager queueManager)
                                                       throws IOException

Throws:

IOException

getPlacementContext

public static ApplicationPlacementContext getPlacementContext(QueueMapping mapping,
 String leafQueueName,
 CapacitySchedulerQueueManager queueManager)
                                                       throws IOException

Throws:

IOException