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

Class UniformBroadcastPolicyManager

java.lang.Object

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

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

All Implemented Interfaces:

FederationPolicyManager

public class UniformBroadcastPolicyManager
extends AbstractPolicyManager

This class represents a simple implementation of a FederationPolicyManager. It combines the basic policies: UniformRandomRouterPolicy and BroadcastAMRMProxyPolicy, which are designed to work together and "spread" the load among sub-clusters uniformly. This simple policy might impose heavy load on the RMs and return more containers than a job requested as all requests are (replicated and) broadcasted.

Field Summary

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

amrmProxyFederationPolicy, LOG, routerFederationPolicy

Constructor Summary

Constructors

Constructor	Description
UniformBroadcastPolicyManager()

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

UniformBroadcastPolicyManager

public UniformBroadcastPolicyManager()

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