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

Class RejectRouterPolicy

java.lang.Object

org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

org.apache.hadoop.yarn.server.federation.policies.router.AbstractRouterPolicy

org.apache.hadoop.yarn.server.federation.policies.router.RejectRouterPolicy

All Implemented Interfaces:

ConfigurableFederationPolicy, FederationRouterPolicy

public class RejectRouterPolicy
extends AbstractRouterPolicy

This FederationRouterPolicy simply rejects all incoming requests. This is useful to prevent applications running in a queue to be run anywhere in the federated cluster.

Constructor Summary

Constructors

Constructor	Description
RejectRouterPolicy()

Method Summary

Modifier and Type	Method	Description
protected SubClusterId	chooseSubCluster(String queue, Map<SubClusterId,SubClusterInfo> preSelectSubclusters)	This method is implemented by the specific policy, and it is used to route both reservations, and applications among a given set of sub-clusters.
void	reinitialize(FederationPolicyInitializationContext federationPolicyContext)	This method is invoked to initialize of update the configuration of policies.

Methods inherited from class org.apache.hadoop.yarn.server.federation.policies.router.AbstractRouterPolicy

getHomeSubcluster, getReservationHomeSubcluster, prefilterSubClusters, validate, validate

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

getActiveSubclusters, getIsDirty, getPolicyContext, getPolicyInfo, setPolicyContext, setPolicyInfo

Methods inherited from class java.lang.Object

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

Constructor Details

RejectRouterPolicy

public RejectRouterPolicy()

Method Details

reinitialize

public void reinitialize(FederationPolicyInitializationContext federationPolicyContext)
                  throws FederationPolicyInitializationException

Description copied from interface: ConfigurableFederationPolicy

This method is invoked to initialize of update the configuration of policies. The implementor should provide try-n-swap semantics, and retain state if possible.

Specified by:

reinitialize in interface ConfigurableFederationPolicy

Overrides:

reinitialize in class AbstractConfigurableFederationPolicy

Parameters:

federationPolicyContext - the new context to provide to implementor.

Throws:

FederationPolicyInitializationException - in case the initialization fails.

chooseSubCluster

protected SubClusterId chooseSubCluster(String queue,
 Map<SubClusterId,SubClusterInfo> preSelectSubclusters)
                                 throws org.apache.hadoop.yarn.exceptions.YarnException

Description copied from class: AbstractRouterPolicy

This method is implemented by the specific policy, and it is used to route both reservations, and applications among a given set of sub-clusters.

Specified by:

chooseSubCluster in class AbstractRouterPolicy

Parameters:

queue - the queue for this application/reservation

preSelectSubclusters - a pre-filter set of sub-clusters

Returns:

the chosen sub-cluster

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - if the policy fails to choose a sub-cluster