@InterfaceAudience.Private @InterfaceStability.Unstable public class HistoryServerFileSystemStateStoreService extends HistoryServerStateStoreService
HistoryServerStateStoreService.HistoryServerState
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
HistoryServerFileSystemStateStoreService() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeStorage()
Implementation-specific shutdown.
|
protected void |
initStorage(org.apache.hadoop.conf.Configuration conf)
Implementation-specific initialization.
|
HistoryServerStateStoreService.HistoryServerState |
loadState()
Load the history server state from the state storage.
|
void |
removeToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId)
Blocking method to remove a delegation token from the state storage.
|
void |
removeTokenMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey key)
Blocking method to remove a delegation token master key.
|
protected void |
startStorage()
Implementation-specific startup.
|
void |
storeToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId,
Long renewDate)
Blocking method to store a delegation token along with the current token
sequence number to the state storage.
|
void |
storeTokenMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey key)
Blocking method to store a delegation token master key.
|
void |
updateToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId,
Long renewDate)
Blocking method to update the expiration of a delegation token
in the state storage.
|
serviceInit, serviceStart, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public HistoryServerFileSystemStateStoreService()
protected void initStorage(org.apache.hadoop.conf.Configuration conf) throws IOException
HistoryServerStateStoreService
initStorage
in class HistoryServerStateStoreService
conf
- the configurationIOException
protected void startStorage() throws IOException
HistoryServerStateStoreService
startStorage
in class HistoryServerStateStoreService
IOException
protected void closeStorage() throws IOException
HistoryServerStateStoreService
closeStorage
in class HistoryServerStateStoreService
IOException
public HistoryServerStateStoreService.HistoryServerState loadState() throws IOException
HistoryServerStateStoreService
loadState
in class HistoryServerStateStoreService
IOException
public void storeToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId, Long renewDate) throws IOException
HistoryServerStateStoreService
storeToken
in class HistoryServerStateStoreService
tokenId
- the token to storerenewDate
- the token renewal deadlineIOException
public void updateToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId, Long renewDate) throws IOException
HistoryServerStateStoreService
updateToken
in class HistoryServerStateStoreService
tokenId
- the token to updaterenewDate
- the new token renewal deadlineIOException
public void removeToken(org.apache.hadoop.mapreduce.v2.api.MRDelegationTokenIdentifier tokenId) throws IOException
HistoryServerStateStoreService
removeToken
in class HistoryServerStateStoreService
tokenId
- the token to removeIOException
public void storeTokenMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey key) throws IOException
HistoryServerStateStoreService
storeTokenMasterKey
in class HistoryServerStateStoreService
key
- the master key to storeIOException
public void removeTokenMasterKey(org.apache.hadoop.security.token.delegation.DelegationKey key) throws IOException
HistoryServerStateStoreService
removeTokenMasterKey
in class HistoryServerStateStoreService
key
- the master key to removeIOException
Copyright © 2017 Apache Software Foundation. All Rights Reserved.