Class AbstractClientRequestInterceptor
java.lang.Object
org.apache.hadoop.yarn.server.router.clientrm.AbstractClientRequestInterceptor
- All Implemented Interfaces:
org.apache.hadoop.conf.Configurable,org.apache.hadoop.yarn.api.ApplicationBaseProtocol,org.apache.hadoop.yarn.api.ApplicationClientProtocol,ClientRequestInterceptor
- Direct Known Subclasses:
DefaultClientRequestInterceptor,FederationClientInterceptor,PassThroughClientRequestInterceptor
public abstract class AbstractClientRequestInterceptor
extends Object
implements ClientRequestInterceptor
Implements the
ClientRequestInterceptor interface and provides common
functionality which can can be used and/or extended by other concrete
interceptor classes.-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hadoop.conf.ConfigurationgetConf()Gets theConfiguration.Gets the nextClientRequestInterceptorin the chain.Get RouterDelegationTokenSecretManager.voidInitializes theClientRequestInterceptor.voidsetConf(org.apache.hadoop.conf.Configuration conf) Sets theConfiguration.voidsetNextInterceptor(ClientRequestInterceptor nextInterceptor) Sets theClientRequestInterceptorin the chain.voidsetTokenSecretManager(RouterDelegationTokenSecretManager tokenSecretManager) Set RouterDelegationTokenSecretManager for specific interceptor to support Token operations, including create Token, update Token, and delete Token.voidshutdown()Disposes theClientRequestInterceptor.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
cancelDelegationToken, getApplicationAttemptReport, getApplicationAttempts, getApplicationReport, getApplications, getContainerReport, getContainers, getDelegationToken, renewDelegationTokenMethods inherited from interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
deleteReservation, failApplicationAttempt, forceKillApplication, getAttributesToNodes, getClusterMetrics, getClusterNodeAttributes, getClusterNodeLabels, getClusterNodes, getLabelsToNodes, getNewApplication, getNewReservation, getNodesToAttributes, getNodeToLabels, getQueueInfo, getQueueUserAcls, getResourceProfile, getResourceProfiles, getResourceTypeInfo, listReservations, moveApplicationAcrossQueues, signalToContainer, submitApplication, submitReservation, updateApplicationPriority, updateApplicationTimeouts, updateReservation
-
Field Details
-
user
protected org.apache.hadoop.security.UserGroupInformation user
-
-
Constructor Details
-
AbstractClientRequestInterceptor
public AbstractClientRequestInterceptor()
-
-
Method Details
-
setNextInterceptor
Sets theClientRequestInterceptorin the chain.- Specified by:
setNextInterceptorin interfaceClientRequestInterceptor- Parameters:
nextInterceptor- the ClientRequestInterceptor to set in the pipeline
-
setConf
public void setConf(org.apache.hadoop.conf.Configuration conf) Sets theConfiguration.- Specified by:
setConfin interfaceorg.apache.hadoop.conf.Configurable
-
getConf
public org.apache.hadoop.conf.Configuration getConf()Gets theConfiguration.- Specified by:
getConfin interfaceorg.apache.hadoop.conf.Configurable
-
init
Initializes theClientRequestInterceptor.- Specified by:
initin interfaceClientRequestInterceptor- Parameters:
userName- the name of the client
-
shutdown
public void shutdown()Disposes theClientRequestInterceptor.- Specified by:
shutdownin interfaceClientRequestInterceptor
-
getNextInterceptor
Gets the nextClientRequestInterceptorin the chain.- Specified by:
getNextInterceptorin interfaceClientRequestInterceptor- Returns:
- the next interceptor in the chain
-
getTokenSecretManager
Description copied from interface:ClientRequestInterceptorGet RouterDelegationTokenSecretManager.- Specified by:
getTokenSecretManagerin interfaceClientRequestInterceptor- Returns:
- Router DelegationTokenSecretManager.
-
setTokenSecretManager
Description copied from interface:ClientRequestInterceptorSet RouterDelegationTokenSecretManager for specific interceptor to support Token operations, including create Token, update Token, and delete Token.- Specified by:
setTokenSecretManagerin interfaceClientRequestInterceptor- Parameters:
tokenSecretManager- Router DelegationTokenSecretManager
-