Package org.apache.hadoop.yarn.server.resourcemanager.federation

Class FederationStateStoreService

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.resourcemanager.federation.FederationStateStoreService

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore, org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore, org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore, org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore, org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore, org.apache.hadoop.yarn.server.federation.store.FederationStateStore

public class FederationStateStoreService
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Implements FederationStateStore and provides a service for participating in the federation membership.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
FederationStateStoreService(RMContext rmContext)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse	addApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.AddReservationHomeSubClusterResponse	addReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.AddReservationHomeSubClusterRequest request)
void	checkVersion()
boolean	cleanUpFinishApplicationsWithRetries(org.apache.hadoop.yarn.api.records.ApplicationId appId, boolean isQuery)	Clean up the federation completed Application.
void	createCleanUpFinishApplicationThread(String stage)	Create a thread that cleans up the app.
org.apache.hadoop.yarn.server.federation.store.records.DeletePoliciesConfigurationsResponse	deleteAllPoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.DeletePoliciesConfigurationsRequest request)
org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterResponse	deleteApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.DeleteSubClusterPoliciesConfigurationsResponse	deletePoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.DeleteSubClusterPoliciesConfigurationsRequest request)
org.apache.hadoop.yarn.server.federation.store.records.DeleteReservationHomeSubClusterResponse	deleteReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.DeleteReservationHomeSubClusterRequest request)
void	deleteStateStore()
org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterResponse	deregisterSubCluster(org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse	getApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse	getApplicationsHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterRequest request)
int	getCurrentKeyId()
org.apache.hadoop.yarn.server.records.Version	getCurrentVersion()
int	getDelegationTokenSeqNum()
org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse	getMasterKeyByDelegationKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse	getPoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse	getPolicyConfiguration(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetReservationHomeSubClusterResponse	getReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetReservationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetReservationsHomeSubClusterResponse	getReservationsHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetReservationsHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.FederationStateStore	getStateStoreClient()
FederationStateStoreHeartbeat	getStateStoreHeartbeatThread()
org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse	getSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest request)
org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse	getSubClusters(org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse	getTokenByRouterStoreToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
int	incrementCurrentKeyId()
int	incrementDelegationTokenSeqNum()
org.apache.hadoop.yarn.server.records.Version	loadVersion()
org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterResponse	registerSubCluster(org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse	removeStoredMasterKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse	removeStoredToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()
void	setDelegationTokenSeqNum(int seqNum)
org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationResponse	setPolicyConfiguration(org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse	storeNewMasterKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse	storeNewToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
void	storeVersion()
org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatResponse	subClusterHeartbeat(org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest request)
org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterResponse	updateApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.UpdateReservationHomeSubClusterResponse	updateReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.UpdateReservationHomeSubClusterRequest request)
org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse	updateStoredToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

close, init

Field Details

LOG

public static final org.slf4j.Logger LOG

Constructor Details

FederationStateStoreService

public FederationStateStoreService(RMContext rmContext)

Method Details

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

getStateStoreClient

@VisibleForTesting
public org.apache.hadoop.yarn.server.federation.store.FederationStateStore getStateStoreClient()

getStateStoreHeartbeatThread

@VisibleForTesting
public FederationStateStoreHeartbeat getStateStoreHeartbeatThread()

getCurrentVersion

public org.apache.hadoop.yarn.server.records.Version getCurrentVersion()

Specified by:

getCurrentVersion in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

loadVersion

public org.apache.hadoop.yarn.server.records.Version loadVersion()
                                                          throws Exception

Specified by:

loadVersion in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Throws:

Exception

storeVersion

public void storeVersion()
                  throws Exception

Specified by:

storeVersion in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Throws:

Exception

checkVersion

public void checkVersion()
                  throws Exception

Specified by:

checkVersion in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Throws:

Exception

deleteStateStore

public void deleteStateStore()
                      throws Exception

Specified by:

deleteStateStore in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Throws:

Exception

getPolicyConfiguration

public org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse getPolicyConfiguration(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest request)
                                                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getPolicyConfiguration in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

setPolicyConfiguration

public org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationResponse setPolicyConfiguration(org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest request)
                                                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

setPolicyConfiguration in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getPoliciesConfigurations

public org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse getPoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsRequest request)
                                                                                                                             throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getPoliciesConfigurations in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

deletePoliciesConfigurations

public org.apache.hadoop.yarn.server.federation.store.records.DeleteSubClusterPoliciesConfigurationsResponse deletePoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.DeleteSubClusterPoliciesConfigurationsRequest request)
                                                                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

deletePoliciesConfigurations in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

deleteAllPoliciesConfigurations

public org.apache.hadoop.yarn.server.federation.store.records.DeletePoliciesConfigurationsResponse deleteAllPoliciesConfigurations(org.apache.hadoop.yarn.server.federation.store.records.DeletePoliciesConfigurationsRequest request)
                                                                                                                            throws Exception

Specified by:

deleteAllPoliciesConfigurations in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Throws:

Exception

registerSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterResponse registerSubCluster(org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest request)
                                                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

registerSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

deregisterSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterResponse deregisterSubCluster(org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest request)
                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

deregisterSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

subClusterHeartbeat

public org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatResponse subClusterHeartbeat(org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest request)
                                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

subClusterHeartbeat in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse getSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest request)
                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getSubClusters

public org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse getSubClusters(org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest request)
                                                                                                 throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getSubClusters in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

addApplicationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse addApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

addApplicationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

updateApplicationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterResponse updateApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest request)
                                                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

updateApplicationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getApplicationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse getApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getApplicationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getApplicationsHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse getApplicationsHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterRequest request)
                                                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getApplicationsHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

deleteApplicationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterResponse deleteApplicationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest request)
                                                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

deleteApplicationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

addReservationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.AddReservationHomeSubClusterResponse addReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.AddReservationHomeSubClusterRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

addReservationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getReservationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.GetReservationHomeSubClusterResponse getReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetReservationHomeSubClusterRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getReservationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getReservationsHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.GetReservationsHomeSubClusterResponse getReservationsHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.GetReservationsHomeSubClusterRequest request)
                                                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getReservationsHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

updateReservationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.UpdateReservationHomeSubClusterResponse updateReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.UpdateReservationHomeSubClusterRequest request)
                                                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

updateReservationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

deleteReservationHomeSubCluster

public org.apache.hadoop.yarn.server.federation.store.records.DeleteReservationHomeSubClusterResponse deleteReservationHomeSubCluster(org.apache.hadoop.yarn.server.federation.store.records.DeleteReservationHomeSubClusterRequest request)
                                                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

deleteReservationHomeSubCluster in interface org.apache.hadoop.yarn.server.federation.store.FederationReservationHomeSubClusterStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

storeNewMasterKey

public org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse storeNewMasterKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
                                                                                                 throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

storeNewMasterKey in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

removeStoredMasterKey

public org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse removeStoredMasterKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
                                                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

removeStoredMasterKey in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getMasterKeyByDelegationKey

public org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyResponse getMasterKeyByDelegationKey(org.apache.hadoop.yarn.server.federation.store.records.RouterMasterKeyRequest request)
                                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getMasterKeyByDelegationKey in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

storeNewToken

public org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse storeNewToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

storeNewToken in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateStoredToken

public org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse updateStoredToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

updateStoredToken in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

removeStoredToken

public org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse removeStoredToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

removeStoredToken in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getTokenByRouterStoreToken

public org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenResponse getTokenByRouterStoreToken(org.apache.hadoop.yarn.server.federation.store.records.RouterRMTokenRequest request)
                                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getTokenByRouterStoreToken in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

incrementDelegationTokenSeqNum

public int incrementDelegationTokenSeqNum()

Specified by:

incrementDelegationTokenSeqNum in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

getDelegationTokenSeqNum

public int getDelegationTokenSeqNum()

Specified by:

getDelegationTokenSeqNum in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

setDelegationTokenSeqNum

public void setDelegationTokenSeqNum(int seqNum)

Specified by:

setDelegationTokenSeqNum in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

getCurrentKeyId

public int getCurrentKeyId()

Specified by:

getCurrentKeyId in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

incrementCurrentKeyId

public int incrementCurrentKeyId()

Specified by:

incrementCurrentKeyId in interface org.apache.hadoop.yarn.server.federation.store.FederationDelegationTokenStateStore

createCleanUpFinishApplicationThread

public void createCleanUpFinishApplicationThread(String stage)

Create a thread that cleans up the app.

Parameters:

stage - rm-start/rm-stop.

cleanUpFinishApplicationsWithRetries

public boolean cleanUpFinishApplicationsWithRetries(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 boolean isQuery)
                                             throws Exception

Clean up the federation completed Application.

Parameters:

appId - app id.

isQuery - true, need to query from statestore, false not query.

Returns:

true, successfully deleted; false, failed to delete or no need to delete

Throws:

Exception - exception occurs.