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

Class WeightedLocalityPolicyManager

java.lang.Object

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

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

All Implemented Interfaces:

FederationPolicyManager

public class WeightedLocalityPolicyManager
extends AbstractPolicyManager

Policy that allows operator to configure "weights" for routing. This picks a LocalityRouterPolicy for the router and a LocalityMulticastAMRMProxyPolicy for the amrmproxy as they are designed to work together.

Field Summary

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

amrmProxyFederationPolicy, LOG, routerFederationPolicy

Constructor Summary

Constructors

Constructor	Description
WeightedLocalityPolicyManager()

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

WeightedLocalityPolicyManager

public WeightedLocalityPolicyManager()

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

@VisibleForTesting
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

@VisibleForTesting
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