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

Class WorkflowPriorityMappingsManager

java.lang.Object

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

@Private
@VisibleForTesting
public class WorkflowPriorityMappingsManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WorkflowPriorityMappingsManager.WorkflowPriorityMapping

Constructor Summary

Constructors

Constructor	Description
WorkflowPriorityMappingsManager()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.api.records.Priority	getMappedPriority(String workflowID, CSQueue queue)
Map<String,Map<String,org.apache.hadoop.yarn.api.records.Priority>>	getWorkflowPriorityMappings()	Get workflow ID to priority mappings for a queue.
static String	getWorkflowPriorityMappingStr(List<WorkflowPriorityMappingsManager.WorkflowPriorityMapping> workflowPriorityMappings)
void	initialize(CapacityScheduler scheduler)
org.apache.hadoop.yarn.api.records.Priority	mapWorkflowPriorityForApp(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, CSQueue queue, String user, org.apache.hadoop.yarn.api.records.Priority priority)

Methods inherited from class java.lang.Object

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

Constructor Details

WorkflowPriorityMappingsManager

public WorkflowPriorityMappingsManager()

Method Details

initialize

@VisibleForTesting
public void initialize(CapacityScheduler scheduler)
                throws IOException

Throws:

IOException

getWorkflowPriorityMappings

public Map<String,Map<String,org.apache.hadoop.yarn.api.records.Priority>> getWorkflowPriorityMappings()

Get workflow ID to priority mappings for a queue.

Returns:

workflowID to priority mappings for a queue

getMappedPriority

public org.apache.hadoop.yarn.api.records.Priority getMappedPriority(String workflowID,
 CSQueue queue)

mapWorkflowPriorityForApp

public org.apache.hadoop.yarn.api.records.Priority mapWorkflowPriorityForApp(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
 CSQueue queue,
 String user,
 org.apache.hadoop.yarn.api.records.Priority priority)
                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getWorkflowPriorityMappingStr

public static String getWorkflowPriorityMappingStr(List<WorkflowPriorityMappingsManager.WorkflowPriorityMapping> workflowPriorityMappings)