public class AutoHDFSNimbus extends AbstractHadoopNimbusPluginAutoCreds
Auto credentials nimbus plugin for HDFS implementation. This class automatically gets HDFS delegation tokens and push it to user’s topology.
CONFIG_KEY_RESOURCES| Constructor and Description |
|---|
AutoHDFSNimbus() |
| Modifier and Type | Method and Description |
|---|---|
void |
doPrepare(Map<String,Object> conf)
Prepare the plugin.
|
void |
doRenew(Map<String,String> credentials,
Map<String,Object> topologyConf,
String topologyOwnerPrincipal) |
protected String |
getConfigKeyString()
The lookup key for the config key string.
|
String |
getCredentialKey(String configKey)
The lookup key for the config key string.
|
protected byte[] |
getHadoopCredentials(Map<String,Object> conf,
String topologyOwnerPrincipal) |
protected byte[] |
getHadoopCredentials(Map<String,Object> conf,
String configKey,
String topologyOwnerPrincipal) |
void |
shutdown() |
fillHadoopConfiguration, getConfigKeys, getCredentials, populateCredentials, prepare, renewclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpopulateCredentialspublic void doPrepare(Map<String,Object> conf)
AbstractHadoopNimbusPluginAutoCredsPrepare the plugin.
doPrepare in class AbstractHadoopNimbusPluginAutoCredsconf - the storm cluster conf set via storm.yamlprotected String getConfigKeyString()
AbstractHadoopNimbusPluginAutoCredsThe lookup key for the config key string.
getConfigKeyString in class AbstractHadoopNimbusPluginAutoCredspublic void shutdown()
protected byte[] getHadoopCredentials(Map<String,Object> conf, String configKey, String topologyOwnerPrincipal)
getHadoopCredentials in class AbstractHadoopNimbusPluginAutoCredsprotected byte[] getHadoopCredentials(Map<String,Object> conf, String topologyOwnerPrincipal)
getHadoopCredentials in class AbstractHadoopNimbusPluginAutoCredspublic void doRenew(Map<String,String> credentials, Map<String,Object> topologyConf, String topologyOwnerPrincipal)
doRenew in class AbstractHadoopNimbusPluginAutoCredspublic String getCredentialKey(String configKey)
CredentialKeyProviderThe lookup key for the config key string.
Copyright © 2021 The Apache Software Foundation. All rights reserved.