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

Class HashBroadcastPolicyManager

java.lang.Object

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

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

All Implemented Interfaces:

FederationPolicyManager

public class HashBroadcastPolicyManager
extends AbstractPolicyManager

Policy that routes applications via hashing of their queuename, and broadcast resource requests. This picks a HashBasedRouterPolicy for the router and a BroadcastAMRMProxyPolicy 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
HashBroadcastPolicyManager()

Method Summary

Modifier and Type	Method	Description
WeightedPolicyInfo	getWeightedPolicyInfo()	We get the WeightedPolicyInfo of the subCluster.
boolean	isSupportWeightedPolicyInfo()	PolicyManager Whether to support WeightedPolicyInfo.
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, serializeConf, setQueue

Methods inherited from class java.lang.Object

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

Constructor Details

HashBroadcastPolicyManager

public HashBroadcastPolicyManager()

Method Details

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