org.apache.storm.hive.security

Class AutoHiveNimbus

java.lang.Object

org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds

org.apache.storm.hive.security.AutoHiveNimbus

All Implemented Interfaces:

CredentialKeyProvider, Shutdownable, ICredentialsRenewer, INimbusCredentialPlugin

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.

Field Summary

Fields

Modifier and Type	Field and Description
String	hiveKeytab
String	hivePrincipal
String	metaStoreURI

Fields inherited from class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds

CONFIG_KEY_RESOURCES

Constructor Summary

Constructors

Constructor and Description
AutoHiveNimbus()

Method Summary

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()

Methods inherited from class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds

fillHadoopConfiguration, getConfigKeys, getCredentials, populateCredentials, prepare, renew

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.security.INimbusCredentialPlugin

populateCredentials

Field Detail

hiveKeytab

public String hiveKeytab

hivePrincipal

public String hivePrincipal

metaStoreURI

public String metaStoreURI

Constructor Detail

AutoHiveNimbus

public AutoHiveNimbus()

Method Detail

doPrepare

public void doPrepare(Map<String,Object> conf)

Description copied from class: AbstractHadoopNimbusPluginAutoCreds

Prepare the plugin.

Specified by:

doPrepare in class AbstractHadoopNimbusPluginAutoCreds

Parameters:

conf - the storm cluster conf set via storm.yaml

getConfigKeyString

protected String getConfigKeyString()

Description copied from class: AbstractHadoopNimbusPluginAutoCreds

The lookup key for the config key string.

Specified by:

getConfigKeyString in class AbstractHadoopNimbusPluginAutoCreds

Returns:

the config key string

shutdown

public void shutdown()

getHadoopCredentials

protected byte[] getHadoopCredentials(Map<String,Object> conf,
                                      String configKey,
                                      String topologyOwnerPrincipal)

Specified by:

getHadoopCredentials in class AbstractHadoopNimbusPluginAutoCreds

getHadoopCredentials

protected byte[] getHadoopCredentials(Map<String,Object> conf,
                                      String topologyOwnerPrincipal)

Specified by:

getHadoopCredentials in class AbstractHadoopNimbusPluginAutoCreds

getHadoopCredentials

protected byte[] getHadoopCredentials(Map<String,Object> conf,
                                      org.apache.hadoop.conf.Configuration configuration,
                                      String topologySubmitterUser)

createHiveConf

public org.apache.hadoop.hive.conf.HiveConf createHiveConf(String metaStoreUri,
                                                           String hiveMetaStorePrincipal)
                                                    throws IOException

Throws:

IOException

doRenew

public void doRenew(Map<String,String> credentials,
                    Map<String,Object> topologyConf,
                    String topologyOwnerPrincipal)

Specified by:

doRenew in class AbstractHadoopNimbusPluginAutoCreds

getCredentialKey

public String getCredentialKey(String configKey)

Description copied from interface: CredentialKeyProvider

The lookup key for the config key string.

Returns:

the config key string