org.apache.storm.common

Class AbstractHadoopAutoCreds

java.lang.Object

org.apache.storm.common.AbstractHadoopAutoCreds

All Implemented Interfaces:

CredentialKeyProvider, IAutoCredentials

Direct Known Subclasses:

AutoHBase, AutoHDFS, AutoHive

public abstract class AbstractHadoopAutoCreds
extends Object
implements IAutoCredentials, CredentialKeyProvider

The base class that for auto credential plugins that abstracts out some of the common functionality.

Constructor Summary

Constructors

Constructor and Description
AbstractHadoopAutoCreds()

Method Summary

Modifier and Type	Method and Description
protected abstract void	doPrepare(Map<String,Object> topoConf) Prepare the plugin.
protected abstract String	getConfigKeyString() The lookup key for the config key string.
Set<org.apache.commons.math3.util.Pair<String,org.apache.hadoop.security.Credentials>>	getCredentials(Map<String,String> credentials)
void	populateCredentials(Map<String,String> credentials)
void	populateSubject(Subject subject, Map<String,String> credentials)
void	prepare(Map<String,Object> topoConf)
void	updateSubject(Subject subject, Map<String,String> credentials)

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.common.CredentialKeyProvider

getCredentialKey

Constructor Detail

AbstractHadoopAutoCreds

public AbstractHadoopAutoCreds()

Method Detail

prepare

public void prepare(Map<String,Object> topoConf)

Specified by:

prepare in interface IAutoCredentials

populateCredentials

public void populateCredentials(Map<String,String> credentials)

Specified by:

populateCredentials in interface IAutoCredentials

populateSubject

public void populateSubject(Subject subject,
                            Map<String,String> credentials)

Specified by:

populateSubject in interface IAutoCredentials

updateSubject

public void updateSubject(Subject subject,
                          Map<String,String> credentials)

Specified by:

updateSubject in interface IAutoCredentials

getCredentials

public Set<org.apache.commons.math3.util.Pair<String,org.apache.hadoop.security.Credentials>> getCredentials(Map<String,String> credentials)

doPrepare

protected abstract void doPrepare(Map<String,Object> topoConf)

Prepare the plugin.

Parameters:

topoConf - the topology conf

getConfigKeyString

protected abstract String getConfigKeyString()

The lookup key for the config key string.

Returns:

the config key string