Uses of Interface
org.apache.hadoop.hdfs.server.federation.fairness.RouterRpcFairnessPolicyController

Packages that use RouterRpcFairnessPolicyController

Package	Description
org.apache.hadoop.hdfs.server.federation.fairness	Includes router handlers fairness manager and policy implementations.
org.apache.hadoop.hdfs.server.federation.router	The router package includes the core services for a HDFS federation router.
org.apache.hadoop.hdfs.server.federation.router.async	This package contains classes that facilitate asynchronous operations within the Hadoop Distributed File System (HDFS) Federation router.

Uses of RouterRpcFairnessPolicyController in org.apache.hadoop.hdfs.server.federation.fairness

Classes in org.apache.hadoop.hdfs.server.federation.fairness that implement RouterRpcFairnessPolicyController

Modifier and Type	Class	Description
class	AbstractRouterRpcFairnessPolicyController	Base fairness policy that implements @RouterRpcFairnessPolicyController.
class	NoRouterRpcFairnessPolicyController	A pass through fairness policy that implements RouterRpcFairnessPolicyController and allows any number of handlers to connect to any specific downstream name service.
class	ProportionRouterRpcFairnessPolicyController	Proportion fairness policy extending AbstractRouterRpcFairnessPolicyController and fetching proportion of handlers from configuration for all available name services, based on the proportion and the total number of handlers, calculate the handlers of all ns.
class	RouterAsyncRpcFairnessPolicyController	When router async rpc enabled, it is recommended to use this fairness controller.
class	StaticRouterRpcFairnessPolicyController	Static fairness policy extending @AbstractRouterRpcFairnessPolicyController and fetching handlers from configuration for all available name services.

Uses of RouterRpcFairnessPolicyController in org.apache.hadoop.hdfs.server.federation.router

Fields in org.apache.hadoop.hdfs.server.federation.router with type parameters of type RouterRpcFairnessPolicyController

Modifier and Type	Field	Description
static final Class<? extends RouterRpcFairnessPolicyController>	RBFConfigKeys.DFS_ROUTER_FAIRNESS_POLICY_CONTROLLER_CLASS_DEFAULT

Methods in org.apache.hadoop.hdfs.server.federation.router that return RouterRpcFairnessPolicyController

Modifier and Type	Method	Description
RouterRpcFairnessPolicyController	RouterRpcClient.getRouterRpcFairnessPolicyController()
static RouterRpcFairnessPolicyController	FederationUtil.newFairnessPolicyController(org.apache.hadoop.conf.Configuration conf)	Creates an instance of an RouterRpcFairnessPolicyController from the configuration.

Methods in org.apache.hadoop.hdfs.server.federation.router with parameters of type RouterRpcFairnessPolicyController

Modifier and Type	Method	Description
protected void	RouterRpcClient.acquirePermit(String nsId, org.apache.hadoop.security.UserGroupInformation ugi, String methodName, RouterRpcFairnessPolicyController controller)	Acquire permit to continue processing the request for specific nsId.
protected <T extends RemoteLocationContext, R> List<RemoteResult<T,R>>	RouterRpcClient.getRemoteResults(RemoteMethod method, long timeOutMs, RouterRpcFairnessPolicyController controller, List<T> orderedLocations, List<Callable<Object>> callables)	Invokes multiple concurrent proxy calls to different clients.
protected void	RouterRpcClient.releasePermit(String nsId, org.apache.hadoop.security.UserGroupInformation ugi, RemoteMethod m, RouterRpcFairnessPolicyController controller)	Release permit for specific nsId after processing against downstream nsId is completed.

Uses of RouterRpcFairnessPolicyController in org.apache.hadoop.hdfs.server.federation.router.async

Methods in org.apache.hadoop.hdfs.server.federation.router.async with parameters of type RouterRpcFairnessPolicyController

Modifier and Type	Method	Description
protected <T extends RemoteLocationContext, R> List<RemoteResult<T,R>>	RouterAsyncRpcClient.getRemoteResults(RemoteMethod method, long timeOutMs, RouterRpcFairnessPolicyController controller, List<T> orderedLocations, List<Callable<Object>> callables)	Invokes multiple concurrent proxy calls to different clients.
protected void	RouterAsyncRpcClient.releasePermit(String nsId, org.apache.hadoop.security.UserGroupInformation ugi, Method m, RouterRpcFairnessPolicyController controller)	Release permit for specific nsId after processing against downstream nsId is completed.