Package org.apache.hadoop.yarn.server.federation.policies.manager

Class HomePolicyManager

java.lang.Object

org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

org.apache.hadoop.yarn.server.federation.policies.manager.HomePolicyManager

All Implemented Interfaces:

FederationPolicyManager

public class HomePolicyManager
extends AbstractPolicyManager

Policy manager which uses the UniformRandomRouterPolicy for the Router and HomeAMRMProxyPolicy as the AMRMProxy policy to find the RM.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

amrmProxyFederationPolicy, LOG, routerFederationPolicy

Constructor Summary

Constructors

Constructor	Description
HomePolicyManager()

Method Summary

Modifier and Type	Method	Description
WeightedPolicyInfo	getWeightedPolicyInfo()	We get the WeightedPolicyInfo of the subCluster.
boolean	isSupportWeightedPolicyInfo()	PolicyManager Whether to support WeightedPolicyInfo.
SubClusterPolicyConfiguration	serializeConf()	This method is invoked to derive a SubClusterPolicyConfiguration.
void	setWeightedPolicyInfo(WeightedPolicyInfo weightedPolicyInfo)	We set the WeightedPolicyInfo of the subCluster.

Methods inherited from class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

getAMRMPolicy, getQueue, getRouterPolicy, setQueue

Methods inherited from class java.lang.Object

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

Constructor Details

HomePolicyManager

public HomePolicyManager()

Method Details

serializeConf

public SubClusterPolicyConfiguration serializeConf()
                                            throws FederationPolicyInitializationException

Description copied from interface: FederationPolicyManager

This method is invoked to derive a SubClusterPolicyConfiguration. This is to be used when writing a policy object in the federation policy store.

Specified by:

serializeConf in interface FederationPolicyManager

Overrides:

serializeConf in class AbstractPolicyManager

Returns:

a valid policy configuration representing this object parametrization.

Throws:

FederationPolicyInitializationException - if the current state cannot be serialized properly

getWeightedPolicyInfo

public WeightedPolicyInfo getWeightedPolicyInfo()

Description copied from class: AbstractPolicyManager

We get the WeightedPolicyInfo of the subCluster.

Specified by:

getWeightedPolicyInfo in interface FederationPolicyManager

Specified by:

getWeightedPolicyInfo in class AbstractPolicyManager

Returns:

WeightedPolicyInfo.

setWeightedPolicyInfo

public void setWeightedPolicyInfo(WeightedPolicyInfo weightedPolicyInfo)

Description copied from class: AbstractPolicyManager

We set the WeightedPolicyInfo of the subCluster.

Specified by:

setWeightedPolicyInfo in interface FederationPolicyManager

Specified by:

setWeightedPolicyInfo in class AbstractPolicyManager

Parameters:

weightedPolicyInfo - weightedPolicyInfo of the subCluster.

isSupportWeightedPolicyInfo

public boolean isSupportWeightedPolicyInfo()

Description copied from interface: FederationPolicyManager

PolicyManager Whether to support WeightedPolicyInfo. Some of PolicyManagers do not support WeightedPolicyInfo.

Returns:

true, supports WeightedPolicyInfo; false, WeightedPolicyInfo is not supported