public class NMTokenSecretManagerInRM
extends org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager
Constructor and Description |
---|
NMTokenSecretManagerInRM(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
activateNextMasterKey()
Activate the new master-key
|
void |
clearNodeSetForAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId) |
org.apache.hadoop.yarn.api.records.NMToken |
createAndGetNMToken(String applicationSubmitter,
org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
org.apache.hadoop.yarn.api.records.Container container) |
org.apache.hadoop.yarn.server.api.records.MasterKey |
getNextKey() |
boolean |
isApplicationAttemptNMTokenPresent(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
org.apache.hadoop.yarn.api.records.NodeId nodeId) |
boolean |
isApplicationAttemptRegistered(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId) |
void |
registerApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId) |
void |
removeNodeKey(org.apache.hadoop.yarn.api.records.NodeId nodeId)
This is to be called when NodeManager reconnects or goes down.
|
void |
rollMasterKey()
Creates a new master-key and sets it as the primary.
|
void |
start() |
void |
stop() |
void |
unregisterApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId) |
createIdentifier, createNewMasterKey, createNMToken, createPassword, getCurrentKey, newInstance, retrievePassword, retrivePasswordInternal
public NMTokenSecretManagerInRM(org.apache.hadoop.conf.Configuration conf)
@InterfaceAudience.Private public void rollMasterKey()
@InterfaceAudience.Private public org.apache.hadoop.yarn.server.api.records.MasterKey getNextKey()
@InterfaceAudience.Private public void activateNextMasterKey()
public void clearNodeSetForAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
public void start()
public void stop()
public org.apache.hadoop.yarn.api.records.NMToken createAndGetNMToken(String applicationSubmitter, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.Container container)
public void registerApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
@InterfaceAudience.Private public boolean isApplicationAttemptRegistered(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
@InterfaceAudience.Private public boolean isApplicationAttemptNMTokenPresent(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.NodeId nodeId)
public void unregisterApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
public void removeNodeKey(org.apache.hadoop.yarn.api.records.NodeId nodeId)
nodeId
- Copyright © 2017 Apache Software Foundation. All Rights Reserved.