Package org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator

Class UniformWeightedLocalityGlobalPolicy

java.lang.Object

org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy

org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.UniformWeightedLocalityGlobalPolicy

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class UniformWeightedLocalityGlobalPolicy
extends GlobalPolicy

Simple policy that generates and updates uniform weighted locality policies.

Constructor Summary

Constructors

Constructor	Description
UniformWeightedLocalityGlobalPolicy()

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager	updatePolicy(String queueName, Map<org.apache.hadoop.yarn.server.federation.store.records.SubClusterId,Map<Class,Object>> clusterInfo, org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager currentManager)	Given a queue, cluster metrics, and policy manager, update the policy to account for the cluster status.

Methods inherited from class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy

getConf, registerPaths, setConf

Methods inherited from class java.lang.Object

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

Constructor Details

UniformWeightedLocalityGlobalPolicy

public UniformWeightedLocalityGlobalPolicy()

Method Details

updatePolicy

protected org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager updatePolicy(String queueName,
 Map<org.apache.hadoop.yarn.server.federation.store.records.SubClusterId,Map<Class,Object>> clusterInfo,
 org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager currentManager)

Description copied from class: GlobalPolicy

Given a queue, cluster metrics, and policy manager, update the policy to account for the cluster status. This method defines the policy generator behavior.

Specified by:

updatePolicy in class GlobalPolicy

Parameters:

queueName - name of the queue

clusterInfo - subClusterId map to cluster information about the SubCluster used to make policy decisions

currentManager - the FederationPolicyManager for the queue's existing policy the manager may be null, in which case the policy will need to be created

Returns:

policy manager that handles the updated (or created) policy