Package org.apache.storm.hbase.security

Class AutoHBaseNimbus

java.lang.Object

org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds

org.apache.storm.hbase.security.AutoHBaseNimbus

All Implemented Interfaces:

CredentialKeyProvider, Shutdownable, ICredentialsRenewer, INimbusCredentialPlugin

public class AutoHBaseNimbus
extends AbstractHadoopNimbusPluginAutoCreds

Auto credentials nimbus plugin for HBase implementation. This class automatically gets HBase delegation tokens and push it to user's topology.

Field Summary

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

CONFIG_KEY_RESOURCES

Constructor Summary

Constructors

Constructor	Description
AutoHBaseNimbus()

Method Summary

Modifier and Type	Method	Description
void	doPrepare(Map<String,Object> conf)	Prepare the plugin.
void	doRenew(Map<String,String> credentials, Map<String,Object> topologyConf, String topologySubmitterUser)
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)
protected byte[]	getHadoopCredentials(Map<String,Object> conf, org.apache.hadoop.conf.Configuration hbaseConf, String topologySubmitterUser)
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

Constructor Details

AutoHBaseNimbus

public AutoHBaseNimbus()

Method Details

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 hbaseConf,
 String topologySubmitterUser)

doRenew

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

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