@InterfaceAudience.Private @InterfaceStability.Unstable public class FileSystemRMStateStore extends RMStateStore
RMStateStore.ApplicationAttemptState, RMStateStore.ApplicationState, RMStateStore.RMDTSecretManagerState, RMStateStore.RMState
Service.STATE
Modifier and Type | Field and Description |
---|---|
protected FileSystem |
fs |
static org.apache.commons.logging.Log |
LOG |
AM_CLIENT_TOKEN_MASTER_KEY_NAME, AM_RM_TOKEN_SERVICE
Constructor and Description |
---|
FileSystemRMStateStore() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeInternal()
Derived classes close themselves using this method.
|
void |
initInternal(Configuration conf)
Derived classes initialize themselves using this method.
|
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 |
removeApplicationState(RMStateStore.ApplicationState appState)
Blocking API
Derived classes must implement this method to remove the state of an
application and its attempts
|
void |
removeRMDelegationTokenState(RMDelegationTokenIdentifier identifier)
Blocking API
Derived classes must implement this method to remove the state of RMDelegationToken
|
void |
removeRMDTMasterKeyState(DelegationKey masterKey)
Blocking API
Derived classes must implement this method to remove the state of
DelegationToken Master Key
|
protected void |
startInternal()
Derived classes start themselves using this method.
|
void |
storeApplicationAttemptState(String attemptId,
ApplicationAttemptStateDataPBImpl attemptStateDataPB)
Blocking API
Derived classes must implement this method to store the state of an
application attempt
|
void |
storeApplicationState(String appId,
ApplicationStateDataPBImpl appStateDataPB)
Blocking API
Derived classes must implement this method to store the state of an
application.
|
void |
storeRMDelegationTokenAndSequenceNumberState(RMDelegationTokenIdentifier identifier,
Long renewDate,
int latestSequenceNumber)
Blocking API
Derived classes must implement this method to store the state of
RMDelegationToken and sequence number
|
void |
storeRMDTMasterKeyState(DelegationKey masterKey)
Blocking API
Derived classes must implement this method to store the state of
DelegationToken Master Key
|
removeApplication, removeApplication, removeRMDelegationToken, removeRMDTMasterKey, serviceInit, serviceStart, serviceStop, setRMDispatcher, storeApplication, storeApplicationAttempt, storeRMDelegationTokenAndSequenceNumber, storeRMDTMasterKey
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final org.apache.commons.logging.Log LOG
protected FileSystem fs
public void initInternal(Configuration conf) throws Exception
RMStateStore
initInternal
in class RMStateStore
Exception
protected void startInternal() throws Exception
RMStateStore
startInternal
in class RMStateStore
Exception
protected void closeInternal() throws Exception
RMStateStore
closeInternal
in class RMStateStore
Exception
public RMStateStore.RMState loadState() throws Exception
RMStateStore
loadState
in class RMStateStore
Exception
public void storeApplicationState(String appId, ApplicationStateDataPBImpl appStateDataPB) throws Exception
RMStateStore
storeApplicationState
in class RMStateStore
Exception
public void storeApplicationAttemptState(String attemptId, ApplicationAttemptStateDataPBImpl attemptStateDataPB) throws Exception
RMStateStore
storeApplicationAttemptState
in class RMStateStore
Exception
public void removeApplicationState(RMStateStore.ApplicationState appState) throws Exception
RMStateStore
removeApplicationState
in class RMStateStore
Exception
public void storeRMDelegationTokenAndSequenceNumberState(RMDelegationTokenIdentifier identifier, Long renewDate, int latestSequenceNumber) throws Exception
RMStateStore
storeRMDelegationTokenAndSequenceNumberState
in class RMStateStore
Exception
public void removeRMDelegationTokenState(RMDelegationTokenIdentifier identifier) throws Exception
RMStateStore
removeRMDelegationTokenState
in class RMStateStore
Exception
public void storeRMDTMasterKeyState(DelegationKey masterKey) throws Exception
RMStateStore
storeRMDTMasterKeyState
in class RMStateStore
Exception
public void removeRMDTMasterKeyState(DelegationKey masterKey) throws Exception
RMStateStore
removeRMDTMasterKeyState
in class RMStateStore
Exception
Copyright © 2013 Apache Software Foundation. All rights reserved.