public class AutoHiveNimbus extends AbstractHadoopNimbusPluginAutoCreds
Auto credentials nimbus plugin for Hive implementation. This class automatically gets Hive delegation tokens and push it to user’s topology.
| Modifier and Type | Field and Description |
|---|---|
String |
hiveKeytab |
String |
hivePrincipal |
String |
metaStoreURI |
CONFIG_KEY_RESOURCES| Constructor and Description |
|---|
AutoHiveNimbus() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.hive.conf.HiveConf |
createHiveConf(String metaStoreUri,
String hiveMetaStorePrincipal) |
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,
org.apache.hadoop.conf.Configuration configuration,
String topologySubmitterUser) |
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 String hiveKeytab
public String hivePrincipal
public String metaStoreURI
public 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 AbstractHadoopNimbusPluginAutoCredsprotected byte[] getHadoopCredentials(Map<String,Object> conf, org.apache.hadoop.conf.Configuration configuration, String topologySubmitterUser)
public org.apache.hadoop.hive.conf.HiveConf createHiveConf(String metaStoreUri, String hiveMetaStorePrincipal) throws IOException
IOExceptionpublic 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.