Package org.apache.storm.hdfs.security
Class AutoHDFSNimbus
java.lang.Object
org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds
org.apache.storm.hdfs.security.AutoHDFSNimbus
- All Implemented Interfaces:
- CredentialKeyProvider,- Shutdownable,- ICredentialsRenewer,- INimbusCredentialPlugin
Auto credentials nimbus plugin for HDFS implementation. This class automatically
 gets HDFS delegation tokens and push it to user's topology.
- 
Field SummaryFields inherited from class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCredsCONFIG_KEY_RESOURCES
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidPrepare the plugin.voiddoRenew(Map<String, String> credentials, Map<String, Object> topologyConf, String topologyOwnerPrincipal) protected StringThe lookup key for the config key string.getCredentialKey(String configKey) The lookup key for the config key string.protected byte[]getHadoopCredentials(Map<String, Object> conf, String topologyOwnerPrincipal) protected byte[]voidshutdown()Methods inherited from class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCredsfillHadoopConfiguration, getConfigKeys, getCredentials, populateCredentials, prepare, renewMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.security.INimbusCredentialPluginpopulateCredentials
- 
Constructor Details- 
AutoHDFSNimbuspublic AutoHDFSNimbus()
 
- 
- 
Method Details- 
doPrepareDescription copied from class:AbstractHadoopNimbusPluginAutoCredsPrepare the plugin.- Specified by:
- doPreparein class- AbstractHadoopNimbusPluginAutoCreds
- Parameters:
- conf- the storm cluster conf set via storm.yaml
 
- 
getConfigKeyStringDescription copied from class:AbstractHadoopNimbusPluginAutoCredsThe lookup key for the config key string.- Specified by:
- getConfigKeyStringin class- AbstractHadoopNimbusPluginAutoCreds
- Returns:
- the config key string
 
- 
shutdownpublic void shutdown()
- 
getHadoopCredentialsprotected byte[] getHadoopCredentials(Map<String, Object> conf, String configKey, String topologyOwnerPrincipal) - Specified by:
- getHadoopCredentialsin class- AbstractHadoopNimbusPluginAutoCreds
 
- 
getHadoopCredentials- Specified by:
- getHadoopCredentialsin class- AbstractHadoopNimbusPluginAutoCreds
 
- 
doRenewpublic void doRenew(Map<String, String> credentials, Map<String, Object> topologyConf, String topologyOwnerPrincipal) - Specified by:
- doRenewin class- AbstractHadoopNimbusPluginAutoCreds
 
- 
getCredentialKeyDescription copied from interface:CredentialKeyProviderThe lookup key for the config key string.- Returns:
- the config key string
 
 
-