Uses of Class
org.apache.hadoop.yarn.server.federation.policies.exceptions.FederationPolicyInitializationException

Packages that use FederationPolicyInitializationException

Package	Description
org.apache.hadoop.yarn.server.federation.policies	Federation Policies.
org.apache.hadoop.yarn.server.federation.policies.amrmproxy	AMRMPRoxy policies.
org.apache.hadoop.yarn.server.federation.policies.dao	DAO objects for serializing/deserializing policy configurations.
org.apache.hadoop.yarn.server.federation.policies.manager	Various implementation of FederationPolicyManager.
org.apache.hadoop.yarn.server.federation.policies.router	Router policies.

Uses of FederationPolicyInitializationException in org.apache.hadoop.yarn.server.federation.policies

Methods in org.apache.hadoop.yarn.server.federation.policies that throw FederationPolicyInitializationException

Modifier and Type	Method	Description
static FederationPolicyManager	FederationPolicyUtils.instantiatePolicyManager(String newType)	A utilize method to instantiate a policy manager class given the type (class name) from SubClusterPolicyConfiguration.
static FederationAMRMProxyPolicy	FederationPolicyUtils.loadAMRMPolicy(String queue, FederationAMRMProxyPolicy oldPolicy, org.apache.hadoop.conf.Configuration conf, FederationStateStoreFacade federationFacade, SubClusterId homeSubClusterId)	Get AMRMProxy policy from state store, using default queue and configuration as fallback.
void	AbstractConfigurableFederationPolicy.reinitialize(FederationPolicyInitializationContext initializationContext)
void	ConfigurableFederationPolicy.reinitialize(FederationPolicyInitializationContext policyContext)	This method is invoked to initialize of update the configuration of policies.
void	AbstractConfigurableFederationPolicy.validate(WeightedPolicyInfo newPolicyInfo)	Overridable validation step for the policy configuration.
static void	FederationPolicyInitializationContextValidator.validate(FederationPolicyInitializationContext policyContext, String myType)

Constructors in org.apache.hadoop.yarn.server.federation.policies that throw FederationPolicyInitializationException

Modifier	Constructor	Description
	RouterPolicyFacade(org.apache.hadoop.conf.Configuration conf, FederationStateStoreFacade facade, SubClusterResolver resolver, SubClusterId homeSubcluster)

Uses of FederationPolicyInitializationException in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

Methods in org.apache.hadoop.yarn.server.federation.policies.amrmproxy that throw FederationPolicyInitializationException

Modifier and Type	Method	Description
void	BroadcastAMRMProxyPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	HomeAMRMProxyPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	LocalityMulticastAMRMProxyPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	RejectAMRMProxyPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	AbstractAMRMProxyPolicy.validate(WeightedPolicyInfo newPolicyInfo)

Uses of FederationPolicyInitializationException in org.apache.hadoop.yarn.server.federation.policies.dao

Methods in org.apache.hadoop.yarn.server.federation.policies.dao that throw FederationPolicyInitializationException

Modifier and Type	Method	Description
static WeightedPolicyInfo	WeightedPolicyInfo.fromByteBuffer(ByteBuffer bb)	Deserializes a WeightedPolicyInfo from a byte UTF-8 JSON representation.
ByteBuffer	WeightedPolicyInfo.toByteBuffer()	Converts the policy into a byte array representation in the input ByteBuffer.

Uses of FederationPolicyInitializationException in org.apache.hadoop.yarn.server.federation.policies.manager

Methods in org.apache.hadoop.yarn.server.federation.policies.manager that throw FederationPolicyInitializationException

Modifier and Type	Method	Description
FederationAMRMProxyPolicy	AbstractPolicyManager.getAMRMPolicy(FederationPolicyInitializationContext federationPolicyContext, FederationAMRMProxyPolicy oldInstance)	This default implementation validates the FederationPolicyInitializationContext, then checks whether it needs to reinstantiate the class (null or mismatching type), and reinitialize the policy.
FederationAMRMProxyPolicy	FederationPolicyManager.getAMRMPolicy(FederationPolicyInitializationContext policyContext, FederationAMRMProxyPolicy oldInstance)	If the current instance is compatible, this method returns the same instance of FederationAMRMProxyPolicy reinitialized with the current context, otherwise a new instance initialized with the current context is provided.
FederationRouterPolicy	AbstractPolicyManager.getRouterPolicy(FederationPolicyInitializationContext federationPolicyContext, FederationRouterPolicy oldInstance)	This default implementation validates the FederationPolicyInitializationContext, then checks whether it needs to reinstantiate the class (null or mismatching type), and reinitialize the policy.
FederationRouterPolicy	FederationPolicyManager.getRouterPolicy(FederationPolicyInitializationContext policyContext, FederationRouterPolicy oldInstance)	If the current instance is compatible, this method returns the same instance of FederationRouterPolicy reinitialized with the current context, otherwise a new instance initialized with the current context is provided.
SubClusterPolicyConfiguration	AbstractPolicyManager.serializeConf()
SubClusterPolicyConfiguration	FederationPolicyManager.serializeConf()	This method is invoked to derive a SubClusterPolicyConfiguration.
SubClusterPolicyConfiguration	HomePolicyManager.serializeConf()
SubClusterPolicyConfiguration	PriorityBroadcastPolicyManager.serializeConf()
SubClusterPolicyConfiguration	WeightedHomePolicyManager.serializeConf()
SubClusterPolicyConfiguration	WeightedLocalityPolicyManager.serializeConf()

Uses of FederationPolicyInitializationException in org.apache.hadoop.yarn.server.federation.policies.router

Methods in org.apache.hadoop.yarn.server.federation.policies.router that throw FederationPolicyInitializationException

Modifier and Type	Method	Description
void	HashBasedRouterPolicy.reinitialize(FederationPolicyInitializationContext federationPolicyContext)
void	LoadBasedRouterPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	LocalityRouterPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	RejectRouterPolicy.reinitialize(FederationPolicyInitializationContext federationPolicyContext)
void	UniformRandomRouterPolicy.reinitialize(FederationPolicyInitializationContext policyContext)
void	AbstractRouterPolicy.validate(WeightedPolicyInfo newPolicyInfo)