|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.resourcemanager.recovery.RMStateStore
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract class RMStateStore
Nested Class Summary | |
---|---|
static class |
RMStateStore.ApplicationAttemptState
State of an application attempt |
static class |
RMStateStore.ApplicationState
State of an application application |
static class |
RMStateStore.RMDTSecretManagerState
|
static class |
RMStateStore.RMState
State of the ResourceManager |
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service |
---|
org.apache.hadoop.service.Service.STATE |
Field Summary | |
---|---|
static org.apache.hadoop.io.Text |
AM_CLIENT_TOKEN_MASTER_KEY_NAME
|
static org.apache.hadoop.io.Text |
AM_RM_TOKEN_SERVICE
|
static org.apache.commons.logging.Log |
LOG
|
Constructor Summary | |
---|---|
RMStateStore()
|
Method Summary | |
---|---|
protected abstract void |
closeInternal()
Derived classes close themselves using this method. |
protected abstract void |
initInternal(org.apache.hadoop.conf.Configuration conf)
Derived classes initialize themselves using this method. |
abstract RMStateStore.RMState |
loadState()
Blocking API The derived class must recover state from the store and return a new RMState object populated with that state This must not be called on the dispatcher thread |
void |
removeApplication(RMApp app)
Non-blocking API ResourceManager services call this to remove an application from the state store This does not block the dispatcher threads There is no notification of completion for this operation. |
void |
removeApplication(RMStateStore.ApplicationState appState)
|
protected abstract void |
removeApplicationState(RMStateStore.ApplicationState appState)
Blocking API Derived classes must implement this method to remove the state of an application and its attempts |
void |
removeRMDelegationToken(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier,
int sequenceNumber)
RMDTSecretManager call this to remove the state of a delegation token |
protected abstract void |
removeRMDelegationTokenState(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier)
Blocking API Derived classes must implement this method to remove the state of RMDelegationToken |
void |
removeRMDTMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey)
RMDTSecretManager call this to remove the state of a master key |
protected abstract void |
removeRMDTMasterKeyState(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey)
Blocking API Derived classes must implement this method to remove the state of DelegationToken Master Key |
void |
serviceInit(org.apache.hadoop.conf.Configuration conf)
|
protected void |
serviceStart()
|
void |
serviceStop()
|
void |
setRMDispatcher(org.apache.hadoop.yarn.event.Dispatcher dispatcher)
Dispatcher used to send state operation completion events to ResourceManager services |
protected abstract void |
startInternal()
Derived classes start themselves using this method. |
void |
storeApplication(RMApp app)
Non-Blocking API ResourceManager services use this to store the application's state This does not block the dispatcher threads RMAppStoredEvent will be sent on completion to notify the RMApp |
void |
storeApplicationAttempt(RMAppAttempt appAttempt)
|
protected abstract void |
storeApplicationAttemptState(String attemptId,
ApplicationAttemptStateDataPBImpl attemptStateData)
Blocking API Derived classes must implement this method to store the state of an application attempt |
protected abstract void |
storeApplicationState(String appId,
ApplicationStateDataPBImpl appStateData)
Blocking API Derived classes must implement this method to store the state of an application. |
void |
storeRMDelegationTokenAndSequenceNumber(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier,
Long renewDate,
int latestSequenceNumber)
RMDTSecretManager call this to store the state of a delegation token and sequence number |
protected abstract void |
storeRMDelegationTokenAndSequenceNumberState(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier,
Long renewDate,
int latestSequenceNumber)
Blocking API Derived classes must implement this method to store the state of RMDelegationToken and sequence number |
void |
storeRMDTMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey)
RMDTSecretManager call this to store the state of a master key |
protected abstract void |
storeRMDTMasterKeyState(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey)
Blocking API Derived classes must implement this method to store the state of DelegationToken Master Key |
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 |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
public static final org.apache.hadoop.io.Text AM_RM_TOKEN_SERVICE
public static final org.apache.hadoop.io.Text AM_CLIENT_TOKEN_MASTER_KEY_NAME
Constructor Detail |
---|
public RMStateStore()
Method Detail |
---|
public void setRMDispatcher(org.apache.hadoop.yarn.event.Dispatcher dispatcher)
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected abstract void initInternal(org.apache.hadoop.conf.Configuration conf) throws Exception
Exception
protected abstract void startInternal() throws Exception
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
protected abstract void closeInternal() throws Exception
Exception
public abstract RMStateStore.RMState loadState() throws Exception
Exception
public void storeApplication(RMApp app)
protected abstract void storeApplicationState(String appId, ApplicationStateDataPBImpl appStateData) throws Exception
Exception
public void storeApplicationAttempt(RMAppAttempt appAttempt)
protected abstract void storeApplicationAttemptState(String attemptId, ApplicationAttemptStateDataPBImpl attemptStateData) throws Exception
Exception
public void storeRMDelegationTokenAndSequenceNumber(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier, Long renewDate, int latestSequenceNumber) throws Exception
Exception
protected abstract void storeRMDelegationTokenAndSequenceNumberState(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier, Long renewDate, int latestSequenceNumber) throws Exception
Exception
public void removeRMDelegationToken(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier, int sequenceNumber) throws Exception
Exception
protected abstract void removeRMDelegationTokenState(org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier rmDTIdentifier) throws Exception
Exception
public void storeRMDTMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey) throws Exception
Exception
protected abstract void storeRMDTMasterKeyState(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey) throws Exception
Exception
public void removeRMDTMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey) throws Exception
Exception
protected abstract void removeRMDTMasterKeyState(org.apache.hadoop.security.token.delegation.DelegationKey delegationKey) throws Exception
Exception
public void removeApplication(RMApp app)
public void removeApplication(RMStateStore.ApplicationState appState)
protected abstract void removeApplicationState(RMStateStore.ApplicationState appState) throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |