Package org.apache.hadoop.yarn.server.router.rmadmin

Class RMAdminProtocolMethod

java.lang.Object

org.apache.hadoop.yarn.server.federation.utils.FederationMethodWrapper

org.apache.hadoop.yarn.server.router.rmadmin.RMAdminProtocolMethod

public class RMAdminProtocolMethod
extends org.apache.hadoop.yarn.server.federation.utils.FederationMethodWrapper

Class to define admin method, params and arguments.

Constructor Summary

Constructors

Constructor	Description
RMAdminProtocolMethod(Class<?>[] pTypes, Object... pParams)

Method Summary

Modifier and Type	Method	Description
protected <R> Collection<R>	invoke(Class<R> clazz, String subClusterId)	Call the method in the protocol according to the subClusterId.
protected <R> Collection<R>	invokeConcurrent(Class<R> clazz)
<R> Collection<R>	invokeConcurrent(FederationRMAdminInterceptor interceptor, Class<R> clazz, String subClusterId)

Methods inherited from class org.apache.hadoop.yarn.server.federation.utils.FederationMethodWrapper

getMethodName, getParams, getTypes, setMethodName

Methods inherited from class java.lang.Object

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

Constructor Details

RMAdminProtocolMethod

public RMAdminProtocolMethod(Class<?>[] pTypes,
 Object... pParams)
                      throws IOException

Throws:

IOException

Method Details

invokeConcurrent

public <R> Collection<R> invokeConcurrent(FederationRMAdminInterceptor interceptor,
 Class<R> clazz,
 String subClusterId)
                                   throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

invokeConcurrent

protected <R> Collection<R> invokeConcurrent(Class<R> clazz)
                                      throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

invokeConcurrent in class org.apache.hadoop.yarn.server.federation.utils.FederationMethodWrapper

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

invoke

protected <R> Collection<R> invoke(Class<R> clazz,
 String subClusterId)
                            throws org.apache.hadoop.yarn.exceptions.YarnException

Call the method in the protocol according to the subClusterId.

Type Parameters:

R - Generic R

Parameters:

clazz - return type

subClusterId - subCluster Id

Returns:

response collection.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - yarn exception.